Function onAllReady

packages/react-dom/src/server/ReactDOMFizzStaticEdge.js:81–107

()

    const onFatalError = reject;

    function onAllReady() {
      const stream = new ReadableStream(
        {
          type: 'bytes',
          pull: (controller): ?Promise<void> => {
            startFlowing(request, controller);
          },
          cancel: (reason): ?Promise<void> => {
            stopFlowing(request);
            abort(request, reason);
          },
        },
        // $FlowFixMe[prop-missing] size() methods are not allowed on byte streams.
        {highWaterMark: 0},
      );

      const result: StaticResult =
        enablePostpone || enableHalt
          ? {
              postponed: getPostponedState(request),
              prelude: stream,
            }
          : ({
              prelude: stream,
            }: any);
      resolve(result);
    }

    const onHeaders = options ? options.onHeaders : undefined;
    let onHeadersImpl;