(name: "stdout" | "stderr")
| 167 | this.records.set(id, record); |
| 168 | |
| 169 | const onData = (name: "stdout" | "stderr") => (chunk: Buffer) => { |
| 170 | const value = new Uint8Array(chunk); |
| 171 | const seq = log.append(name, value); |
| 172 | record.lastOutputAt = this.opts.now(); |
| 173 | record.subscriber?.enqueue({ id, seq, name, value }); |
| 174 | }; |
| 175 | child.stdout?.on("data", onData("stdout")); |
| 176 | child.stderr?.on("data", onData("stderr")); |
| 177 |