• Producer (生产者)

    Producer (生产者)

    Producer 的任务是生产 Observable 所发出的值。

    1. class Producer {
    2. constructor(){
    3. this.i = 0;
    4. }
    5. nextValue(){
    6. return i++;
    7. }
    8. }

    使用 Producer

    1. let stream$ = Rx.Observable.create( (observer) => {
    2. observer.next( Producer.nextValue() )
    3. observer.next( Producer.nextValue() )
    4. })

    在 Observable Anatomy 章节中并没有在示例中使用 Producer,大多数 Observables 都是通过辅助方法创建的,在这些方法中会有内部的 Producer 来生产值,这些值通过 observer 的 observer.next 方法发出