bufferWhen
优质
小牛编辑
131浏览
2023-12-01
bufferWhen
函数签名: bufferWhen(closingSelector: function): Observable
收集值,直到关闭选择器发出值才发出缓冲的值。
示例
示例 1: 发出基于 interval 缓冲的值
( StackBlitz | jsBin | jsFiddle )
// RxJS v6+
import { interval } from 'rxjs';
import { bufferWhen } from 'rxjs/operators';
// 每1秒发出值
const oneSecondInterval = interval(1000);
// 返回的 observable 每5秒发出值
const fiveSecondInterval = () => interval(5000);
// 每5秒发出缓冲的值
const bufferWhenExample = oneSecondInterval.pipe(bufferWhen(fiveSecondInterval));
// 输出值
// 输出: [0,1,2,3]...[4,5,6,7,8]
const subscribe = bufferWhenExample.subscribe(val =>
console.log('Emitted Buffer: ', val)
);
其他资源
- bufferWhen :newspaper: - 官方文档
源码: https://github.com/ReactiveX/rxjs/blob/master/src/internal/operators/bufferWhen.ts