Function deserializeJSONStream

packages/start/src/fns/serialization.ts:203–227

(response: Response | Request)

}

export async function deserializeJSONStream(response: Response | Request) {
  if (!response.body) {
    throw new Error("missing body");
  }
  const reader = new SerovalChunkReader(response.body);
  const result = await reader.next();
  if (!result.done) {
    const refs = new Map();

    function interpretChunk(chunk: string): unknown {
      const value = fromCrossJSON(JSON.parse(chunk) as SerovalNode, {
        refs,
        disabledFeatures: DISABLED_FEATURES,
        depthLimit: MAX_SERIALIZATION_DEPTH_LIMIT,
        plugins: DEFAULT_PLUGINS,
      });
      return value;
    }

    void reader.drain(interpretChunk);

    return interpretChunk(result.value);
  }
  return undefined;
}

export async function deserializeJSStream(id: string, response: Request | Response) {
  if (!response.body) {