Function feed

node/tests/transport.test.ts:48–50

(env: Envelope)

  (t as unknown as { __fromCore: PassThrough }).__fromCore = fromCore;

  const feed = (env: Envelope) => {
    fromCore.write(sizeDelimitedEncode(EnvelopeSchema, env));
  };
  // crash: EOF the core->client stream → the read loop ends → all pending fail.
  const crash = () => {
    fromCore.end();