• 创建操作符
    • create
    • range

    创建操作符

    create

    当你刚起步或者只是想要测试一些东西时，倾向于从 create() 操作符入手。它接收一个有 observer 参数的函数。在前面的一些章节中已提及过，比如 Observable 包装章节。函数签名如下：

    1. Rx.Observable.create([fn])

    示例如下：

    1. Rx.Observable.create(observer => {
    2.     observer.next( 1 );
    3. })

    range

    函数签名

    1. Rx.Observable.range([start],[count])

    示例

    1. let stream$ = Rx.Observable.range(1,3)
    3. // 发出 1,2,3