finish
将输入的 stream 或者 subjection 结束后的数据进行组合,返回一个新的流
类型
typescripttype combine: (...args: (Stream | Subjection)[]) => Stream;
详情
- 所有输入的流都 结束 后,新的流才会发出第一个数据
- 新的流发出第一个数据后也会结束
- 所有输入的流取消订阅后,新的流也会取消订阅
示例
typescriptimport { $, finish } from "fluth"; const stream1$ = $(1); const stream2$ = $("hello"); const stream3$ = $(true); const finish$ = finish(stream1$, stream2$, stream3$); finish$.then((value) => console.log(value)); console.log(finish$.value); // 打印: undefined stream1$.next(2); stream1$.next(3, true); stream2$.next("world", true); stream3$.next(false, true); // 打印: [3, "world", false]