RxJS 是一个流式编程库，它提供了许多操作符来帮助我们处理数据流。其中，buffer 和 bufferTime 操作符可以帮助我们将数据流转换为缓冲区，以便我们在一定条件下对缓冲区中的数据进行操作。
buffer 操作符
buffer 操作符可以将数据流转换为缓冲区，当缓冲区达到一定条件时，将缓冲区中的数据作为一个数组发射出去。
语法
buffer(closingNotifier: Observable): Observable
参数
- closingNotifier: 用来关闭缓冲区的 observable。
示例
下面的示例演示了如何使用 buffer 操作符将数据流转换为缓冲区，并在缓冲区中有 3 个数据时将缓冲区中的数据作为一个数组发射出去。
import { fromEvent } from 'rxjs';
import { buffer } from 'rxjs/operators';
const clicks = fromEvent(document, 'click');
const buffered = clicks.pipe(buffer(clicks.pipe(delay(1000))));
buffered.subscribe(x => console.log(x));在上面的代码中，我们先使用 fromEvent 创建了一个点击事件的 observable，然后通过 buffer 操作符将点击事件的 observable 作为 closingNotifier，当点击事件停止 1 秒时，缓冲区中的数据将作为一个数组发射出去。
bufferTime 操作符
bufferTime 操作符可以将数据流转换为缓冲区，当缓冲区达到一定时间时，将缓冲区中的数据作为一个数组发射出去。
语法
bufferTime(bufferTimeSpan: number, bufferCreationInterval?: number, maxBufferSize?: number, scheduler?: SchedulerLike): OperatorFunction<T, T[]>
参数
- bufferTimeSpan: 缓冲区的时间间隔，以毫秒为单位。
- bufferCreationInterval: 缓冲区的创建间隔，以毫秒为单位。如果未指定，则使用 bufferTimeSpan 的值。
- maxBufferSize: 缓冲区的最大大小。如果未指定，则缓冲区的大小不受限制。
- scheduler: 用于确定缓冲区何时创建和发射的调度程序。
示例
下面的示例演示了如何使用 bufferTime 操作符将数据流转换为缓冲区，并在缓冲区中有 3 个数据或 1 秒钟过去时将缓冲区中的数据作为一个数组发射出去。
import { fromEvent } from 'rxjs';
import { bufferTime } from 'rxjs/operators';
const clicks = fromEvent(document, 'click');
const buffered = clicks.pipe(bufferTime(1000));
buffered.subscribe(x => console.log(x));在上面的代码中，我们先使用 fromEvent 创建了一个点击事件的 observable，然后通过 bufferTime 操作符将点击事件的 observable 转换为缓冲区，当缓冲区中有 3 个数据或 1 秒钟过去时，缓冲区中的数据将作为一个数组发射出去。
总结
buffer 和 bufferTime 操作符可以帮助我们将数据流转换为缓冲区，以便我们在一定条件下对缓冲区中的数据进行操作。在实际开发中，我们可以根据具体需求选择使用这些操作符，从而更加高效地处理数据流。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/660a0aebd10417a2228d8e9f