()
| 316 | } |
| 317 | |
| 318 | const emitUpdate = () => { |
| 319 | pendingCommandOutputEmitTimer = undefined |
| 320 | lastCommandOutputEmitAt = Date.now() |
| 321 | void queueCommandOutputMessage(latestCompressedOutput, true) |
| 322 | } |
| 323 | |
| 324 | const elapsed = Date.now() - lastCommandOutputEmitAt |
| 325 | if (elapsed >= commandOutputStreamThrottleMs) { |
no test coverage detected