Function decodeRuntimeEvents

packages/computer/src/runtime/wire.ts:52–73

(
  source: ReadableStream<Uint8Array>,
)

}

export function decodeRuntimeEvents(
  source: ReadableStream<Uint8Array>,
): ReadableStream<WorkspaceRuntimeEvent<ExecEncoding>> {
  const decoder = new TextDecoder();
  let buffered = "";
  return source.pipeThrough(
    new TransformStream<Uint8Array, WorkspaceRuntimeEvent<ExecEncoding>>({
      transform(chunk, controller) {
        buffered += decoder.decode(chunk, { stream: true });
        const lines = buffered.split("\n");
        buffered = lines.pop() ?? "";
        for (const line of lines) {
          if (line) controller.enqueue(decodeFrame(JSON.parse(line) as RuntimeFrame));
        }
      },
      flush(controller) {
        buffered += decoder.decode();
        if (buffered.trim()) controller.enqueue(decodeFrame(JSON.parse(buffered) as RuntimeFrame));
      },
    }),
  );
}