| 1 |
|
| 2 | import { Transform, TransformCallback } from 'stream';
|
| 3 | export interface BatchStreamOptions {
|
| 4 | wait?: number;
|
| 5 | }
|
| 6 | export default class BatchStream extends Transform {
|
| 7 | bufferedBatch: Buffer | null;
|
| 8 | timeout: NodeJS.Timer | null;
|
| 9 | waitThreshold: number;
|
| 10 | constructor(options?: BatchStreamOptions);
|
| 11 | flush(): void;
|
| 12 | _transform(chunk: Buffer, encoding: string, callback: TransformCallback): void;
|
| 13 | _flush(callback: TransformCallback): void;
|
| 14 | }
|
| 15 | //# sourceMappingURL=BatchStream.d.ts.map |
| \ | No newline at end of file |