()
| 2425 | } |
| 2426 | // Flush queue when batch size is reached |
| 2427 | async flushIfNeeded(): Promise<void> { |
| 2428 | if (this.queuedSize >= this.batchSize) { |
| 2429 | await this.flush(); |
| 2430 | } |
| 2431 | } |
| 2432 | // Force flush all queued buffers |
| 2433 | async flush(): Promise<void> { |
| 2434 | const promise = new Promise<void>((resolve, reject) => { |
no test coverage detected