排队观察
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:
评论0
最新资源