预览

type thenPlugin = (unsubscribe: () => void) => void
type executePlugin = ( promise: Promise<any>, unsubscribe: () => void ) => Promise<any>

plugin: {
  then: thenPlugin[]
  execute: executePlugin[]
}

Details
plugin 可以定义两种插件: then插件和execute插件：
- then插件在then方法被调用时执行。它们将当前节点的unsubscribe函数作为参数，可以实现统一的取消订阅功能。
- execute插件在execute方法被调用时执行。它们将当前节点的promise和当前节点的unsubscribe函数作为参数，返回的promise将被传递给下一个execute插件，最终返回的promise数据将传递给下一个的then节点。

then

类型

typescript

type OnFulfilled<T> = Parameters<Promise<T>['then']>[0]
type OnRejected<T> = Parameters<Promise<T>['catch']>[0]

then<T>(
  onFulfilled: OnFulfilled<T>,
  onRejected?: OnRejected<unknown>,
): Subjection

详情
then订阅者，用法和promise保持一致，返回订阅节点的 Subjection 实例

thenOnce

类型

typescript

type OnFulfilled<T> = Parameters<Promise<T>['then']>[0]
type OnRejected<T> = Parameters<Promise<T>['catch']>[0]

thenOnce<T>(
  onFulfilled: OnFulfilled<T>,
  onRejected?: OnRejected<unknown>,
): Subjection

thenImmediate

类型

typescript

type OnFulfilled<T> = Parameters<Promise<T>['then']>[0]
type OnRejected<T> = Parameters<Promise<T>['catch']>[0]

thenImmediate<T>(
  onFulfilled: OnFulfilled<T>,
  onRejected?: OnRejected<unknown>,
): Subjection

详情
thenImmediate相比then方法差异点在于父订阅节点如果execute过，则采用thenImmediate会立即触发订阅子节点的execute

catch

类型

typescript

type OnRejected<T> = Parameters<Promise<T>['catch']>[0]

catch(onRejected: OnRejected<unknown>): Subjection

详情
对订阅节点进行catch，用法和promise保持一致，返回订阅节点的 Subjection 实例

finally

类型

typescript

type OnFinally<T> = Parameters<Promise<T>['finally']>[0]

finally(onFinally: OnFinally<unknown>): Subjection

详情
对订阅节点进行finally，用法和promise保持一致，返回订阅节点的 Subjection 实例

unsubscribe

类型
typescript
```
unsubscribe(): void
```
详情
取消节点的订阅，不同于promise的无法取消，stream的订阅可以随时取消
警告
取消当前节点订阅，当前节点的then之后的节点也会全部取消订阅

setUnsubscribeCallback

类型

typescript

setUnsubscribeCallback(callback: () => void): void

详情
设置取消节点订阅的回调函数

finish

类型
typescript
```
finish: Promise<any>;
```
详情
流结束后触发的promise，会早于订阅节点自动取消订阅触发

execute

类型
typescript
```
execute: () => void
```
详情
主动执行当前节点，数据采用上一次流过该节点的数据，如果节点从来没有执行过，则不会执行。
WARNING
执行当前节点，当前节点then之后的节点也会执行，相当于在当前节点推流

pause

类型
typescript
```
pause: () => void
```
详情
暂停当前流，执行pause方法后，所有订阅的节点都不会执行

restart

类型
typescript
```
restart: () => void
```
详情
重启当前流，执行restart方法后，所有订阅的节点开始接受流的推送并执行

类型

typescript

next(payload: any, finishFlag?: boolean): void;

详情
当前流推送数据，payload为数据，当设置为Promise.reject(xxx)时，后续then表现和promise的then一致；第二个参数代表当前流是否结束，当设置为true后续next将不再执行

预览 ​

Stream ​

Subjection ​

plugin ​

then ​

thenOnce ​

thenImmediate ​

catch ​

finally ​

unsubscribe ​

setUnsubscribeCallback ​

finish ​

execute ​

pause ​

restart ​

next ​

预览

Stream

Subjection

plugin

then

thenOnce

thenImmediate

catch

finally

unsubscribe

setUnsubscribeCallback

finish

execute

pause

restart

next