@tanbo/stream
Advanced tools
Comparing version 0.0.7 to 0.0.8
@@ -8,2 +8,3 @@ export * from './audit-time'; | ||
export * from './map'; | ||
export * from './share'; | ||
export * from './skip'; | ||
@@ -10,0 +11,0 @@ export * from './switch-map'; |
@@ -8,2 +8,3 @@ export * from './audit-time'; | ||
export * from './map'; | ||
export * from './share'; | ||
export * from './skip'; | ||
@@ -10,0 +11,0 @@ export * from './switch-map'; |
{ | ||
"name": "@tanbo/stream", | ||
"version": "0.0.7", | ||
"version": "0.0.8", | ||
"description": "A data stream lib", | ||
@@ -5,0 +5,0 @@ "main": "./public-api.js", |
@@ -335,2 +335,26 @@ Stream 数据流处理库 | ||
### share | ||
让多个订阅共享同一个数据源,而不是创建新的 | ||
```ts | ||
const sharedObs = interval().pipe(share()) | ||
sharedObs.subscribe(value => { | ||
console.log(value) | ||
}) | ||
setTimeout(() => { | ||
sharedObs.subscribe(value => { | ||
console.log(value) | ||
}) | ||
}, 2100) | ||
// 输出: | ||
// 0 | ||
// 1 | ||
// 2 | ||
// 2 | ||
// 3 | ||
// 3 | ||
``` | ||
### skip | ||
@@ -337,0 +361,0 @@ |
53473
63
1180
431