Function
bufferOutput
(state: ActiveProcess, chunk: ProcessOutputChunk)
Source from the content-addressed store, hash-verified
| 47 | } |
| 48 | |
| 49 | function bufferOutput(state: ActiveProcess, chunk: ProcessOutputChunk): void { |
| 50 | state.output.push(chunk) |
| 51 | while (state.output.length > MAX_BUFFERED_CHUNKS) state.output.shift() |
| 52 | } |
| 53 | |
| 54 | function scheduleCleanup(local: LocalProcessState, id: string, processState: ActiveProcess): void { |
| 55 | if (processState.cleanup) clearTimeout(processState.cleanup) |
Tested by
no test coverage detected