partition
将输入的 stream 或者 subjection 按照条件函数进行分区,返回两个流,第一个是满足条件的流,第二个是不满足条件的流
类型
typescripttype partition: ( stream$: Stream | Subjection, predicate: (this: any, value: any, index: number) => boolean, thisArg?: any, ) => Stream[];
详情
- 将输入的流按照条件函数进行区分,返回两个流:第一个是满足条件的流,第二个是不满足条件的流
- 输入的流取消订阅后,两个返回的流也会取消订阅
- 输入的流 结束 后,对应返回的流也会结束