当前位置：首页 > 文档资料 > RxJS 5 ultimate 中文版 >

OBSERVABLES - Producer

优质

小牛编辑

137浏览

2023-12-01

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

class Producer {
   constructor(){
     this.i = 0;
   }
   nextValue(){
     return i++;
   }
}

使用 Producer

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

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

免责声明：以上内容版权归原作者所有，如有侵犯您的原创版权请告知，我们将尽快删除相关内容。感谢每一位辛勤著写的作者，感谢每一位的分享。