* Returns the Redis key of the buffer's main list (the queue of pending * rows). Used by base-class methods for ground-truth size and * observability. Subclasses MUST override.
()
| 116 | * observability. Subclasses MUST override. |
| 117 | */ |
| 118 | protected getRedisListKey(): string { |
| 119 | throw new Error(`${this.name}: subclass must override getRedisListKey()`); |
| 120 | } |
| 121 | |
| 122 | /** |
| 123 | * Yield control back to the event loop. Use periodically inside CPU-bound |