Class Chunker<T>

Collects items up to countLimit, calling writer before sizeLimit would be exceeded.

Remarks

Always call onIdle when done to ensure that the last writer call is made.

Type Parameters

  • T

    Type of items to be chunked

Hierarchy

  • Chunker

Constructors

constructor

Properties

_backgroundWriter _errors _iterableQueue _pendingItems _pendingSize _writer

Accessors

errors pendingCount pendingSize

Methods

enqueue flush onIdle

Constructors

constructor

  • Collects items up to countLimit, calling writer before sizeLimit would be exceeded.

    Type Parameters

    • T

      Type of items to be chunked

    Parameters

    • options: IChunkerOptions<T>

      Chunker options

    Returns Chunker<T>

    Remarks

    Always call onIdle when done to ensure that the last writer call is made.

Properties

Private Readonly _backgroundWriter

_backgroundWriter: Promise<void>

Private Readonly _errors

_errors: Errors = []

Private Readonly _iterableQueue

_iterableQueue: IterableQueue<T> = ...

Private _pendingItems

_pendingItems: T[] = []

Private _pendingSize

_pendingSize: number = 0

Private Readonly _writer

_writer: WriterFunc<T>

Accessors

errors

  • get errors(): Errors

  • Accumulated errors from background flushes

    Returns Errors

pendingCount

  • get pendingCount(): number

  • Number of items pending

    Returns number

pendingSize

  • get pendingSize(): number

  • Sum of the user-defined size of all pending items

    Returns number

Methods

enqueue

  • Adds an item to the pending queue, flushing the queue before adding the item if the new item would cause the item limit or size limit to be exceeded.

    Parameters

    • item: T

      Item to be added to the queue

    Returns Promise<void>

Private flush

  • Calls writer for any pending items and clears pending items queue.

    Returns Promise<void>

    Result from writer function or undefined if no items pending

onIdle

  • Wait for all background writes to finish. MUST be called before exit to ensure no lost writes.

    Returns Promise<void>

Settings

Member Visibility

Theme

On This Page

Generated using TypeDoc