Function dropHeartbeats

packages/computerd/src/cli/computerd.ts:110–120

(stream: ReadableStream<ComputerdExecEvent>)

// RPC layer. Heartbeats are a local observability signal only; the
// computer-rpc wire contract carries only stdout, stderr, and exit.
function dropHeartbeats(stream: ReadableStream<ComputerdExecEvent>): ReadableStream<RpcExecEvent> {
  return stream.pipeThrough(
    new TransformStream<ComputerdExecEvent, RpcExecEvent>({
      transform(event, controller) {
        if (event.name !== "heartbeat") {
          controller.enqueue(event as RpcExecEvent);
        }
      },
    }),
  );
}

interface ComputerdInfo {
  backend: FUSEBackend;