Class BatchTransform<T>

Transform stream that batches records into arrays

Type Parameters

T = any

Hierarchy

Transform
- BatchTransform

Index

Constructors

Methods

_transform _flush

Constructors

constructor

new BatchTransform<T = any>(
options: BatchTransformOptions<T>,
): BatchTransform<T>
Type Parameters
- T = any
Parameters
- options: BatchTransformOptions<T>
Returns BatchTransform<T>
Overrides Transform.constructor
- Defined in streams/transforms.ts:118

Methods

_transform

_transform(
    record: T,
    encoding: string,
    callback: (error?: Error | null, data?: T[]) => void,
): void
Transform - batch records
Parameters
- record: T
- encoding: string
- callback: (error?: Error | null, data?: T[]) => void
Returns void
Overrides Transform._transform
- Defined in streams/transforms.ts:129

_flush

_flush(callback: (error?: Error | null, data?: T[]) => void): void
Flush remaining records in buffer
Parameters
- callback: (error?: Error | null, data?: T[]) => void
Returns void
Overrides Transform._flush
- Defined in streams/transforms.ts:144