(delayMs: number)
| 64 | } |
| 65 | |
| 66 | function createReadyProcWithDelay(delayMs: number): MockProc { |
| 67 | const proc = createBaseProc() |
| 68 | proc.send = (message: unknown) => { |
| 69 | const msg = message as { type?: string; executionId?: number; request?: { requestId?: string } } |
| 70 | if (msg.type === 'execute') { |
| 71 | setTimeout(() => { |
| 72 | proc.emit('message', { |
| 73 | type: 'result', |
| 74 | executionId: msg.executionId, |
| 75 | result: { result: msg.request?.requestId ?? 'unknown', stdout: '' }, |
| 76 | }) |
| 77 | }, delayMs) |
| 78 | } |
| 79 | return true |
| 80 | } |
| 81 | setImmediate(() => proc.emit('message', { type: 'ready' })) |
| 82 | return proc |
| 83 | } |
| 84 | |
| 85 | type ControllableReadyProc = { |
| 86 | spawn: SpawnFactory |
no test coverage detected