()
| 2491 | } |
| 2492 | // Force flush all accumulated buffers |
| 2493 | async flush(): Promise<void> { |
| 2494 | if (this.buffers.length > 0) { |
| 2495 | const combinedBuffer = Buffer.concat(this.buffers); |
| 2496 | await this.file.write(combinedBuffer); |
| 2497 | this.buffers = []; // Reset buffers |
| 2498 | } |
| 2499 | } |
| 2500 | } |
| 2501 | // Stream-based version of writeFieldBuffered with better memory management |
| 2502 | const writeFieldBufferedStream = async (streamWriter: StreamWriter, schemaFields: SchemaField[]) => { |
no outgoing calls
no test coverage detected