rx q:RxJS运算符可一次为观察者提供服务 源码

排队观察 npm i queued-observable 一个通常会同时将数据发送给它的所有观察者: import { Subject } from 'rxjs' import { take } from 'rxjs/operators' const source = new Subject ( ) source . pipe ( take ( 2 ) ) . subscribe ( v => console . log ( 'A: ' + v ) ) source . pipe ( take ( 3 ) ) . subscribe ( v => console . log ( 'B: ' + v ) ) source . next ( 1 ) source . next ( 2 ) source . next ( 3 ) source . next ( 4 ) // A: 1, B: