( events: WorkspaceExecEvent<E>[], )
| 35 | } |
| 36 | |
| 37 | async function roundTrip<E extends "utf8" | undefined>( |
| 38 | events: WorkspaceExecEvent<E>[], |
| 39 | ): Promise<WorkspaceExecEvent<E>[]> { |
| 40 | const bytes = encodeExecEvents(streamOf(events)); |
| 41 | return collect(decodeExecEvents<E>(bytes)) as Promise<WorkspaceExecEvent<E>[]>; |
| 42 | } |
| 43 | |
| 44 | describe("exec wire codec — utf8 events", () => { |
| 45 | it("round-trips stdout/stderr/exit events", async () => { |
no test coverage detected