文件名称:rx-q:RxJS运算符可一次为观察者提供服务
文件大小:57KB
文件格式:ZIP
更新时间:2024-04-16 15:54:04
TypeScript
排队观察 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:
【文件预览】:
rx-q-main
----.eslintrc(1KB)
----conf()
--------rollup()
--------typescript()
----package.json(2KB)
----.github()
--------workflows()
----LICENSE(1KB)
----package-lock.json(169KB)
----src()
--------test()
--------keyed-q.ts(944B)
--------q.ts(621B)
--------index.ts(67B)
----tsconfig.json(176B)
----.gitignore(2KB)
----README.md(2KB)
----.gitignore copy(2KB)