Skip to content

Commit

Permalink
Reunify createRequest
Browse files Browse the repository at this point in the history
We can split these at the startWork layer instead.
  • Loading branch information
sebmarkbage committed Aug 22, 2023
1 parent 2072780 commit 0528ab5
Show file tree
Hide file tree
Showing 7 changed files with 25 additions and 96 deletions.
7 changes: 4 additions & 3 deletions packages/react-dom/src/server/ReactDOMFizzServerBrowser.js
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@ import ReactVersion from 'shared/ReactVersion';

import {
createRequest,
resumeRequest,
startWork,
startFlowing,
abort,
Expand Down Expand Up @@ -166,13 +165,15 @@ function resume(
allReady.catch(() => {});
reject(error);
}
const request = resumeRequest(
const request = createRequest(
children,
postponedState,
postponedState.resumableState,
createRenderState(
postponedState.resumableState,
options ? options.nonce : undefined,
),
postponedState.rootFormatContext,
postponedState.progressiveChunkSize,
options ? options.onError : undefined,
onAllReady,
onShellReady,
Expand Down
7 changes: 4 additions & 3 deletions packages/react-dom/src/server/ReactDOMFizzServerEdge.js
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@ import ReactVersion from 'shared/ReactVersion';

import {
createRequest,
resumeRequest,
startWork,
startFlowing,
abort,
Expand Down Expand Up @@ -166,13 +165,15 @@ function resume(
allReady.catch(() => {});
reject(error);
}
const request = resumeRequest(
const request = createRequest(
children,
postponedState,
postponedState.resumableState,
createRenderState(
postponedState.resumableState,
options ? options.nonce : undefined,
),
postponedState.rootFormatContext,
postponedState.progressiveChunkSize,
options ? options.onError : undefined,
onAllReady,
onShellReady,
Expand Down
7 changes: 4 additions & 3 deletions packages/react-dom/src/server/ReactDOMFizzServerNode.js
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@ import ReactVersion from 'shared/ReactVersion';

import {
createRequest,
resumeRequest,
startWork,
startFlowing,
abort,
Expand Down Expand Up @@ -135,13 +134,15 @@ function resumeRequestImpl(
postponedState: PostponedState,
options: void | ResumeOptions,
) {
return resumeRequest(
return createRequest(
children,
postponedState,
postponedState.resumableState,
createRenderState(
postponedState.resumableState,
options ? options.nonce : undefined,
),
postponedState.rootFormatContext,
postponedState.progressiveChunkSize,
options ? options.onError : undefined,
options ? options.onAllReady : undefined,
options ? options.onShellReady : undefined,
Expand Down
6 changes: 4 additions & 2 deletions packages/react-dom/src/server/ReactDOMFizzStaticBrowser.js
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ import type {PostponedState} from 'react-server/src/ReactFizzServer';
import ReactVersion from 'shared/ReactVersion';

import {
createPrerenderRequest,
createRequest,
startWork,
startFlowing,
abort,
Expand Down Expand Up @@ -78,14 +78,16 @@ function prerender(
options ? options.bootstrapModules : undefined,
options ? options.unstable_externalRuntimeSrc : undefined,
);
const request = createPrerenderRequest(
const request = createRequest(
children,
resources,
createRenderState(resources, undefined),
createRootFormatContext(options ? options.namespaceURI : undefined),
options ? options.progressiveChunkSize : undefined,
options ? options.onError : undefined,
onAllReady,
undefined,
undefined,
onFatalError,
options ? options.onPostpone : undefined,
);
Expand Down
6 changes: 4 additions & 2 deletions packages/react-dom/src/server/ReactDOMFizzStaticEdge.js
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ import type {PostponedState} from 'react-server/src/ReactFizzServer';
import ReactVersion from 'shared/ReactVersion';

import {
createPrerenderRequest,
createRequest,
startWork,
startFlowing,
abort,
Expand Down Expand Up @@ -78,14 +78,16 @@ function prerender(
options ? options.bootstrapModules : undefined,
options ? options.unstable_externalRuntimeSrc : undefined,
);
const request = createPrerenderRequest(
const request = createRequest(
children,
resources,
createRenderState(resources, undefined),
createRootFormatContext(options ? options.namespaceURI : undefined),
options ? options.progressiveChunkSize : undefined,
options ? options.onError : undefined,
onAllReady,
undefined,
undefined,
onFatalError,
options ? options.onPostpone : undefined,
);
Expand Down
6 changes: 4 additions & 2 deletions packages/react-dom/src/server/ReactDOMFizzStaticNode.js
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ import {Writable, Readable} from 'stream';
import ReactVersion from 'shared/ReactVersion';

import {
createPrerenderRequest,
createRequest,
startWork,
startFlowing,
abort,
Expand Down Expand Up @@ -92,14 +92,16 @@ function prerenderToNodeStream(
options ? options.bootstrapModules : undefined,
options ? options.unstable_externalRuntimeSrc : undefined,
);
const request = createPrerenderRequest(
const request = createRequest(
children,
resumableState,
createRenderState(resumableState, undefined),
createRootFormatContext(options ? options.namespaceURI : undefined),
options ? options.progressiveChunkSize : undefined,
options ? options.onError : undefined,
onAllReady,
undefined,
undefined,
onFatalError,
options ? options.onPostpone : undefined,
);
Expand Down
82 changes: 1 addition & 81 deletions packages/react-server/src/ReactFizzServer.js
Original file line number Diff line number Diff line change
Expand Up @@ -281,7 +281,7 @@ function defaultErrorHandler(error: mixed) {

function noop(): void {}

function createRequestImpl(
export function createRequest(
children: ReactNodeList,
resumableState: ResumableState,
renderState: RenderState,
Expand Down Expand Up @@ -352,86 +352,6 @@ function createRequestImpl(
return request;
}

export function createRequest(
children: ReactNodeList,
resumableState: ResumableState,
renderState: RenderState,
rootFormatContext: FormatContext,
progressiveChunkSize: void | number,
onError: void | ((error: mixed) => ?string),
onAllReady: void | (() => void),
onShellReady: void | (() => void),
onShellError: void | ((error: mixed) => void),
onFatalError: void | ((error: mixed) => void),
onPostpone: void | ((reason: string) => void),
): Request {
return createRequestImpl(
children,
resumableState,
renderState,
rootFormatContext,
progressiveChunkSize,
onError,
onAllReady,
onShellReady,
onShellError,
onFatalError,
onPostpone,
);
}

export function createPrerenderRequest(
children: ReactNodeList,
resumableState: ResumableState,
renderState: RenderState,
rootFormatContext: FormatContext,
progressiveChunkSize: void | number,
onError: void | ((error: mixed) => ?string),
onAllReady: void | (() => void),
onFatalError: void | ((error: mixed) => void),
onPostpone: void | ((reason: string) => void),
): Request {
return createRequestImpl(
children,
resumableState,
renderState,
rootFormatContext,
progressiveChunkSize,
onError,
onAllReady,
undefined,
undefined,
onFatalError,
onPostpone,
);
}

export function resumeRequest(
children: ReactNodeList,
postponedState: PostponedState,
renderState: RenderState,
onError: void | ((error: mixed) => ?string),
onAllReady: void | (() => void),
onShellReady: void | (() => void),
onShellError: void | ((error: mixed) => void),
onFatalError: void | ((error: mixed) => void),
onPostpone: void | ((reason: string) => void),
): Request {
return createRequestImpl(
children,
postponedState.resumableState,
renderState,
postponedState.rootFormatContext,
postponedState.progressiveChunkSize,
onError,
onAllReady,
onShellReady,
onShellError,
onFatalError,
onPostpone,
);
}

let currentRequest: null | Request = null;

export function resolveRequest(): null | Request {
Expand Down

0 comments on commit 0528ab5

Please sign in to comment.