Properties
Protected Optional buffer
buffer?: T
Protected Readonly concat
concat: ((left: T, right: T) => T)
Protected emitInterval
emitInterval: number
Protected Readonly length
length: ((what: T) => number)
Protected maxChunkSize
maxChunkSize: number
Protected onDataEmitter
onDataEmitter: Emitter<T> = ...
Protected Readonly slice
slice: ((what: T, start?: number, end?: number) => T)
Type declaration
- (what: T, start?: number, end?: number): T
Parameters
what: T
Optional start: number
Optional end: number
Returns T
Protected Optional timeout
timeout?: Timeout
This component will buffer whatever is pushed to it and emit chunks back every BufferingStreamOptions.emitInterval. It will also ensure that the emitted chunks never exceed BufferingStreamOptions.maxChunkSize.