Class BufferingStream<T>

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.

Type Parameters

  • T

Hierarchy (view full)

Constructors

constructor

Properties

buffer? concat emitInterval length maxChunkSize onDataEmitter slice timeout?

Accessors

onData

Methods

dispose emitBufferedChunk push

Constructors

constructor

Properties

Protected Optional buffer

buffer?: T

Protected Readonly concat

concat: ((left, right) => T)

Type declaration

    • (left, right): T

    • Parameters

      • left: T
      • right: T

      Returns T

Protected emitInterval

emitInterval: number

Protected Readonly length

length: ((what) => number)

Type declaration

    • (what): number

    • Parameters

      • what: T

      Returns number

Protected maxChunkSize

maxChunkSize: number

Protected onDataEmitter

onDataEmitter: Emitter<T> = ...

Protected Readonly slice

slice: ((what, start?, end?) => T)

Type declaration

    • (what, start?, end?): T

    • Parameters

      • what: T
      • Optional start: number
      • Optional end: number

      Returns T

Protected Optional timeout

timeout?: Timeout

Accessors

onData

Methods

dispose

Protected emitBufferedChunk

push

Settings

Member Visibility

Theme

On This Page

constructorbufferconcatemitIntervallengthmaxChunkSizeonDataEmitterslicetimeoutonDatadisposeemitBufferedChunkpush