()
| 2431 | } |
| 2432 | // Force flush all queued buffers |
| 2433 | async flush(): Promise<void> { |
| 2434 | const promise = new Promise<void>((resolve, reject) => { |
| 2435 | this.writePromises.push({ resolve, reject }); |
| 2436 | }); |
| 2437 | this.processQueue(); |
| 2438 | return promise; |
| 2439 | } |
| 2440 | // Close the stream |
| 2441 | async close(): Promise<void> { |
| 2442 | await this.flush(); |
no test coverage detected