Function serializeToJSStream

packages/start/src/fns/serialization.ts:69–89

(id: string, value: any)

}

export function serializeToJSStream(id: string, value: any) {
  return new ReadableStream({
    start(controller) {
      crossSerializeStream(value, {
        scopeId: id,
        plugins: DEFAULT_PLUGINS,
        onSerialize(data: string, initial: boolean) {
          controller.enqueue(
            createChunk(initial ? `(${getCrossReferenceHeader(id)},${data})` : data),
          );
        },
        onDone() {
          controller.close();
        },
        onError(error: any) {
          controller.error(error);
        },
      });
    },
  });
}

export function serializeToJSONStream(value: any) {
  return new ReadableStream({