Function drain

packages/computer/src/backends/worker-javascript/frames.ts:40–52

(controller: TransformStreamDefaultController<RuntimeFrame>, final: boolean)

  const decoder = new TextDecoder();
  let buffer = "";
  const drain = (controller: TransformStreamDefaultController<RuntimeFrame>, final: boolean) => {
    let nl = buffer.indexOf("\n");
    while (nl !== -1) {
      const line = buffer.slice(0, nl);
      buffer = buffer.slice(nl + 1);
      if (line.length > 0) controller.enqueue(parseRuntimeFrame(line));
      nl = buffer.indexOf("\n");
    }
    if (final && buffer.length > 0) {
      controller.enqueue(parseRuntimeFrame(buffer));
      buffer = "";
    }
  };
  return source.pipeThrough(
    new TransformStream<Uint8Array, RuntimeFrame>({
      transform(chunk, controller) {