Function deserializeJSStream

packages/start/src/fns/serialization.ts:229–250

(id: string, response: Request | Response)

}

export async function deserializeJSStream(id: string, response: Request | Response) {
  if (!response.body) {
    throw new Error("missing body");
  }
  const reader = new SerovalChunkReader(response.body);

  const result = await reader.next();

  if (!result.done) {
    reader.drain(deserialize).then(
      () => {
        // @ts-ignore
        delete $R[id];
      },
      () => {
        // no-op
      },
    );
    return deserialize(result.value);
  }
  return undefined;
}