{"patch":"diff --git a\/packages\/react-debug-tools\/src\/ReactDebugHooks.js b\/packages\/react-debug-tools\/src\/ReactDebugHooks.js\nindex c1258c2dcd..a57c38ab10 100644\n--- a\/packages\/react-debug-tools\/src\/ReactDebugHooks.js\n+++ b\/packages\/react-debug-tools\/src\/ReactDebugHooks.js\n@@ -7,13 +7,7 @@\n * @flow\n *\/\n \n-import type {\n- MutableSource,\n- MutableSourceGetSnapshotFn,\n- MutableSourceSubscribeFn,\n- ReactContext,\n- ReactProviderType,\n-} from 'shared\/ReactTypes';\n+import type {ReactContext, ReactProviderType} from 'shared\/ReactTypes';\n import type {\n Fiber,\n Dispatcher as DispatcherType,\n@@ -261,23 +255,6 @@ function useMemo(\n return value;\n }\n \n-function useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n-): Snapshot {\n- \/\/ useMutableSource() composes multiple hooks internally.\n- \/\/ Advance the current hook index the same number of times\n- \/\/ so that subsequent hooks have the right memoized state.\n- nextHook(); \/\/ MutableSource\n- nextHook(); \/\/ State\n- nextHook(); \/\/ Effect\n- nextHook(); \/\/ Effect\n- const value = getSnapshot(source._source);\n- hookLog.push({primitive: 'MutableSource', stackError: new Error(), value});\n- return value;\n-}\n-\n function useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -357,7 +334,6 @@ const Dispatcher: DispatcherType = {\n useRef,\n useState,\n useTransition,\n- useMutableSource,\n useSyncExternalStore,\n useDeferredValue,\n useOpaqueIdentifier,\ndiff --git a\/packages\/react-debug-tools\/src\/__tests__\/ReactHooksInspectionIntegration-test.js b\/packages\/react-debug-tools\/src\/__tests__\/ReactHooksInspectionIntegration-test.js\nindex b13bec22d2..2e6896ef16 100644\n--- a\/packages\/react-debug-tools\/src\/__tests__\/ReactHooksInspectionIntegration-test.js\n+++ b\/packages\/react-debug-tools\/src\/__tests__\/ReactHooksInspectionIntegration-test.js\n@@ -1019,43 +1019,6 @@ describe('ReactHooksInspectionIntegration', () => {\n ]);\n });\n \n- it('should support composite useMutableSource hook', () => {\n- const createMutableSource =\n- React.createMutableSource || React.unstable_createMutableSource;\n- const useMutableSource =\n- React.useMutableSource || React.unstable_useMutableSource;\n-\n- const mutableSource = createMutableSource({}, () => 1);\n- function Foo(props) {\n- useMutableSource(\n- mutableSource,\n- () => 'snapshot',\n- () => {},\n- );\n- React.useMemo(() => 'memo', []);\n- return

;\n- }\n- const renderer = ReactTestRenderer.create();\n- const childFiber = renderer.root.findByType(Foo)._currentFiber();\n- const tree = ReactDebugTools.inspectHooksOfFiber(childFiber);\n- expect(tree).toEqual([\n- {\n- id: 0,\n- isStateEditable: false,\n- name: 'MutableSource',\n- value: 'snapshot',\n- subHooks: [],\n- },\n- {\n- id: 1,\n- isStateEditable: false,\n- name: 'Memo',\n- value: 'memo',\n- subHooks: [],\n- },\n- ]);\n- });\n-\n \/\/ @gate experimental || www\n it('should support composite useSyncExternalStore hook', () => {\n const useSyncExternalStore = React.unstable_useSyncExternalStore;\ndiff --git a\/packages\/react-dom\/src\/client\/ReactDOMRoot.js b\/packages\/react-dom\/src\/client\/ReactDOMRoot.js\nindex ba062fc3f7..3bde63dc67 100644\n--- a\/packages\/react-dom\/src\/client\/ReactDOMRoot.js\n+++ b\/packages\/react-dom\/src\/client\/ReactDOMRoot.js\n@@ -8,7 +8,7 @@\n *\/\n \n import type {Container} from '.\/ReactDOMHostConfig';\n-import type {MutableSource, ReactNodeList} from 'shared\/ReactTypes';\n+import type {ReactNodeList} from 'shared\/ReactTypes';\n import type {FiberRoot} from 'react-reconciler\/src\/ReactInternalTypes';\n \n export type RootType = {\n@@ -24,7 +24,6 @@ export type CreateRootOptions = {\n hydrationOptions?: {\n onHydrated?: (suspenseNode: Comment) => void,\n onDeleted?: (suspenseNode: Comment) => void,\n- mutableSources?: Array>,\n ...\n },\n \/\/ END OF TODO\n@@ -35,7 +34,6 @@ export type CreateRootOptions = {\n \n export type HydrateRootOptions = {\n \/\/ Hydration options\n- hydratedSources?: Array>,\n onHydrated?: (suspenseNode: Comment) => void,\n onDeleted?: (suspenseNode: Comment) => void,\n \/\/ Options for all roots\n@@ -61,7 +59,6 @@ import {\n createContainer,\n updateContainer,\n findHostInstanceWithNoPortals,\n- registerMutableSourceForHydration,\n } from 'react-reconciler\/src\/ReactFiberReconciler';\n import invariant from 'shared\/invariant';\n import {ConcurrentRoot} from 'react-reconciler\/src\/ReactRootTags';\n@@ -129,11 +126,6 @@ export function createRoot(\n const hydrate = options != null && options.hydrate === true;\n const hydrationCallbacks =\n (options != null && options.hydrationOptions) || null;\n- const mutableSources =\n- (options != null &&\n- options.hydrationOptions != null &&\n- options.hydrationOptions.mutableSources) ||\n- null;\n \/\/ END TODO\n \n const isStrictMode = options != null && options.unstable_strictMode === true;\n@@ -159,15 +151,6 @@ export function createRoot(\n container.nodeType === COMMENT_NODE ? container.parentNode : container;\n listenToAllSupportedEvents(rootContainerElement);\n \n- \/\/ TODO: Delete this path\n- if (mutableSources) {\n- for (let i = 0; i < mutableSources.length; i++) {\n- const mutableSource = mutableSources[i];\n- registerMutableSourceForHydration(root, mutableSource);\n- }\n- }\n- \/\/ END TODO\n-\n return new ReactDOMRoot(root);\n }\n \n@@ -185,7 +168,6 @@ export function hydrateRoot(\n \/\/ For now we reuse the whole bag of options since they contain\n \/\/ the hydration callbacks.\n const hydrationCallbacks = options != null ? options : null;\n- const mutableSources = (options != null && options.hydratedSources) || null;\n const isStrictMode = options != null && options.unstable_strictMode === true;\n \n let concurrentUpdatesByDefaultOverride = null;\n@@ -208,13 +190,6 @@ export function hydrateRoot(\n \/\/ This can't be a comment node since hydration doesn't work on comment nodes anyway.\n listenToAllSupportedEvents(container);\n \n- if (mutableSources) {\n- for (let i = 0; i < mutableSources.length; i++) {\n- const mutableSource = mutableSources[i];\n- registerMutableSourceForHydration(root, mutableSource);\n- }\n- }\n-\n \/\/ Render the initial children\n updateContainer(initialChildren, root, null, null);\n \ndiff --git a\/packages\/react-dom\/src\/server\/ReactPartialRendererHooks.js b\/packages\/react-dom\/src\/server\/ReactPartialRendererHooks.js\nindex bfc21b0623..175a394a4d 100644\n--- a\/packages\/react-dom\/src\/server\/ReactPartialRendererHooks.js\n+++ b\/packages\/react-dom\/src\/server\/ReactPartialRendererHooks.js\n@@ -9,12 +9,7 @@\n \n import type {Dispatcher as DispatcherType} from 'react-reconciler\/src\/ReactInternalTypes';\n \n-import type {\n- MutableSource,\n- MutableSourceGetSnapshotFn,\n- MutableSourceSubscribeFn,\n- ReactContext,\n-} from 'shared\/ReactTypes';\n+import type {ReactContext} from 'shared\/ReactTypes';\n import type PartialRenderer from '.\/ReactPartialRenderer';\n \n import {validateContextBounds} from '.\/ReactPartialRendererContext';\n@@ -466,18 +461,6 @@ export function useCallback(\n return useMemo(() => callback, deps);\n }\n \n-\/\/ TODO Decide on how to implement this hook for server rendering.\n-\/\/ If a mutation occurs during render, consider triggering a Suspense boundary\n-\/\/ and falling back to client rendering.\n-function useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n-): Snapshot {\n- resolveCurrentlyRenderingComponent();\n- return getSnapshot(source._source);\n-}\n-\n function useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -536,8 +519,6 @@ export const Dispatcher: DispatcherType = {\n useDeferredValue,\n useTransition,\n useOpaqueIdentifier,\n- \/\/ Subscriptions are not setup in a server environment.\n- useMutableSource,\n useSyncExternalStore,\n };\n \ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberBeginWork.new.js b\/packages\/react-reconciler\/src\/ReactFiberBeginWork.new.js\nindex d9874bba34..894bc523e4 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberBeginWork.new.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberBeginWork.new.js\n@@ -12,7 +12,6 @@ import type {LazyComponent as LazyComponentType} from 'react\/src\/ReactLazy';\n import type {Fiber, FiberRoot} from '.\/ReactInternalTypes';\n import type {TypeOfMode} from '.\/ReactTypeOfMode';\n import type {Lanes, Lane} from '.\/ReactFiberLane.new';\n-import type {MutableSource} from 'shared\/ReactTypes';\n import type {\n SuspenseState,\n SuspenseListRenderState,\n@@ -145,7 +144,6 @@ import {\n isSuspenseInstancePending,\n isSuspenseInstanceFallback,\n registerSuspenseInstanceRetry,\n- supportsHydration,\n isPrimaryRenderer,\n supportsPersistence,\n getOffscreenContainerProps,\n@@ -224,7 +222,6 @@ import {\n RetryAfterError,\n NoContext,\n } from '.\/ReactFiberWorkLoop.new';\n-import {setWorkInProgressVersion} from '.\/ReactMutableSource.new';\n import {\n requestCacheFromPool,\n pushCacheProvider,\n@@ -1303,21 +1300,6 @@ function updateHostRoot(current, workInProgress, renderLanes) {\n \/\/ We always try to hydrate. If this isn't a hydration pass there won't\n \/\/ be any children to hydrate which is effectively the same thing as\n \/\/ not hydrating.\n-\n- if (supportsHydration) {\n- const mutableSourceEagerHydrationData =\n- root.mutableSourceEagerHydrationData;\n- if (mutableSourceEagerHydrationData != null) {\n- for (let i = 0; i < mutableSourceEagerHydrationData.length; i += 2) {\n- const mutableSource = ((mutableSourceEagerHydrationData[\n- i\n- ]: any): MutableSource);\n- const version = mutableSourceEagerHydrationData[i + 1];\n- setWorkInProgressVersion(mutableSource, version);\n- }\n- }\n- }\n-\n const child = mountChildFibers(\n workInProgress,\n null,\ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberBeginWork.old.js b\/packages\/react-reconciler\/src\/ReactFiberBeginWork.old.js\nindex 74037fbe96..264e723b28 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberBeginWork.old.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberBeginWork.old.js\n@@ -12,7 +12,6 @@ import type {LazyComponent as LazyComponentType} from 'react\/src\/ReactLazy';\n import type {Fiber, FiberRoot} from '.\/ReactInternalTypes';\n import type {TypeOfMode} from '.\/ReactTypeOfMode';\n import type {Lanes, Lane} from '.\/ReactFiberLane.old';\n-import type {MutableSource} from 'shared\/ReactTypes';\n import type {\n SuspenseState,\n SuspenseListRenderState,\n@@ -145,7 +144,6 @@ import {\n isSuspenseInstancePending,\n isSuspenseInstanceFallback,\n registerSuspenseInstanceRetry,\n- supportsHydration,\n isPrimaryRenderer,\n supportsPersistence,\n getOffscreenContainerProps,\n@@ -224,7 +222,6 @@ import {\n RetryAfterError,\n NoContext,\n } from '.\/ReactFiberWorkLoop.old';\n-import {setWorkInProgressVersion} from '.\/ReactMutableSource.old';\n import {\n requestCacheFromPool,\n pushCacheProvider,\n@@ -1303,21 +1300,6 @@ function updateHostRoot(current, workInProgress, renderLanes) {\n \/\/ We always try to hydrate. If this isn't a hydration pass there won't\n \/\/ be any children to hydrate which is effectively the same thing as\n \/\/ not hydrating.\n-\n- if (supportsHydration) {\n- const mutableSourceEagerHydrationData =\n- root.mutableSourceEagerHydrationData;\n- if (mutableSourceEagerHydrationData != null) {\n- for (let i = 0; i < mutableSourceEagerHydrationData.length; i += 2) {\n- const mutableSource = ((mutableSourceEagerHydrationData[\n- i\n- ]: any): MutableSource);\n- const version = mutableSourceEagerHydrationData[i + 1];\n- setWorkInProgressVersion(mutableSource, version);\n- }\n- }\n- }\n-\n const child = mountChildFibers(\n workInProgress,\n null,\ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberCompleteWork.new.js b\/packages\/react-reconciler\/src\/ReactFiberCompleteWork.new.js\nindex 1382439f1e..e7d6f40e98 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberCompleteWork.new.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberCompleteWork.new.js\n@@ -30,8 +30,6 @@ import type {SuspenseContext} from '.\/ReactFiberSuspenseContext.new';\n import type {OffscreenState} from '.\/ReactFiberOffscreenComponent';\n import type {Cache, SpawnedCachePool} from '.\/ReactFiberCacheComponent.new';\n \n-import {resetWorkInProgressVersions as resetMutableSourceWorkInProgressVersions} from '.\/ReactMutableSource.new';\n-\n import {now} from '.\/Scheduler';\n \n import {\n@@ -854,7 +852,6 @@ function completeWork(\n }\n popHostContainer(workInProgress);\n popTopLevelLegacyContextObject(workInProgress);\n- resetMutableSourceWorkInProgressVersions();\n if (fiberRoot.pendingContext) {\n fiberRoot.context = fiberRoot.pendingContext;\n fiberRoot.pendingContext = null;\ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberCompleteWork.old.js b\/packages\/react-reconciler\/src\/ReactFiberCompleteWork.old.js\nindex 746e3d4b57..6e8406fc05 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberCompleteWork.old.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberCompleteWork.old.js\n@@ -30,8 +30,6 @@ import type {SuspenseContext} from '.\/ReactFiberSuspenseContext.old';\n import type {OffscreenState} from '.\/ReactFiberOffscreenComponent';\n import type {Cache, SpawnedCachePool} from '.\/ReactFiberCacheComponent.old';\n \n-import {resetWorkInProgressVersions as resetMutableSourceWorkInProgressVersions} from '.\/ReactMutableSource.old';\n-\n import {now} from '.\/Scheduler';\n \n import {\n@@ -854,7 +852,6 @@ function completeWork(\n }\n popHostContainer(workInProgress);\n popTopLevelLegacyContextObject(workInProgress);\n- resetMutableSourceWorkInProgressVersions();\n if (fiberRoot.pendingContext) {\n fiberRoot.context = fiberRoot.pendingContext;\n fiberRoot.pendingContext = null;\ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberHooks.new.js b\/packages\/react-reconciler\/src\/ReactFiberHooks.new.js\nindex 4b4d7ad7e9..5f1c30a834 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberHooks.new.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberHooks.new.js\n@@ -7,12 +7,7 @@\n * @flow\n *\/\n \n-import type {\n- MutableSource,\n- MutableSourceGetSnapshotFn,\n- MutableSourceSubscribeFn,\n- ReactContext,\n-} from 'shared\/ReactTypes';\n+import type {ReactContext} from 'shared\/ReactTypes';\n import type {Fiber, Dispatcher, HookType} from '.\/ReactInternalTypes';\n import type {Lanes, Lane} from '.\/ReactFiberLane.new';\n import type {HookFlags} from '.\/ReactHookEffectTags';\n@@ -50,7 +45,6 @@ import {\n intersectLanes,\n isTransitionLane,\n markRootEntangled,\n- markRootMutableRead,\n NoTimestamp,\n } from '.\/ReactFiberLane.new';\n import {\n@@ -102,12 +96,6 @@ import {\n makeClientIdInDEV,\n makeOpaqueHydratingObject,\n } from '.\/ReactFiberHostConfig';\n-import {\n- getWorkInProgressVersion,\n- markSourceAsDirty,\n- setWorkInProgressVersion,\n- warnAboutMultipleRenderersDEV,\n-} from '.\/ReactMutableSource.new';\n import {getIsRendering} from '.\/ReactCurrentFiber';\n import {logStateUpdateScheduled} from '.\/DebugTracing';\n import {markStateUpdateScheduled} from '.\/SchedulingProfiler';\n@@ -118,7 +106,6 @@ import {\n entangleTransitions,\n } from '.\/ReactUpdateQueue.new';\n import {pushInterleavedQueue} from '.\/ReactFiberInterleavedUpdates.new';\n-import {getIsStrictModeForDevtools} from '.\/ReactFiberReconciler.new';\n import {warnOnSubscriptionInsideStartTransition} from 'shared\/ReactFeatureFlags';\n \n const {ReactCurrentDispatcher, ReactCurrentBatchConfig} = ReactSharedInternals;\n@@ -948,322 +935,6 @@ function rerenderReducer(\n return [newState, dispatch];\n }\n \n-type MutableSourceMemoizedState = {|\n- refs: {\n- getSnapshot: MutableSourceGetSnapshotFn,\n- setSnapshot: Snapshot => void,\n- },\n- source: MutableSource,\n- subscribe: MutableSourceSubscribeFn,\n-|};\n-\n-function readFromUnsubscribedMutableSource(\n- root: FiberRoot,\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n-): Snapshot {\n- if (__DEV__) {\n- warnAboutMultipleRenderersDEV(source);\n- }\n-\n- const getVersion = source._getVersion;\n- const version = getVersion(source._source);\n-\n- \/\/ Is it safe for this component to read from this source during the current render?\n- let isSafeToReadFromSource = false;\n-\n- \/\/ Check the version first.\n- \/\/ If this render has already been started with a specific version,\n- \/\/ we can use it alone to determine if we can safely read from the source.\n- const currentRenderVersion = getWorkInProgressVersion(source);\n- if (currentRenderVersion !== null) {\n- \/\/ It's safe to read if the store hasn't been mutated since the last time\n- \/\/ we read something.\n- isSafeToReadFromSource = currentRenderVersion === version;\n- } else {\n- \/\/ If there's no version, then this is the first time we've read from the\n- \/\/ source during the current render pass, so we need to do a bit more work.\n- \/\/ What we need to determine is if there are any hooks that already\n- \/\/ subscribed to the source, and if so, whether there are any pending\n- \/\/ mutations that haven't been synchronized yet.\n- \/\/\n- \/\/ If there are no pending mutations, then `root.mutableReadLanes` will be\n- \/\/ empty, and we know we can safely read.\n- \/\/\n- \/\/ If there *are* pending mutations, we may still be able to safely read\n- \/\/ if the currently rendering lanes are inclusive of the pending mutation\n- \/\/ lanes, since that guarantees that the value we're about to read from\n- \/\/ the source is consistent with the values that we read during the most\n- \/\/ recent mutation.\n- isSafeToReadFromSource = isSubsetOfLanes(\n- renderLanes,\n- root.mutableReadLanes,\n- );\n-\n- if (isSafeToReadFromSource) {\n- \/\/ If it's safe to read from this source during the current render,\n- \/\/ store the version in case other components read from it.\n- \/\/ A changed version number will let those components know to throw and restart the render.\n- setWorkInProgressVersion(source, version);\n- }\n- }\n-\n- if (isSafeToReadFromSource) {\n- const snapshot = getSnapshot(source._source);\n- if (__DEV__) {\n- if (typeof snapshot === 'function') {\n- console.error(\n- 'Mutable source should not return a function as the snapshot value. ' +\n- 'Functions may close over mutable values and cause tearing.',\n- );\n- }\n- }\n- return snapshot;\n- } else {\n- \/\/ This handles the special case of a mutable source being shared between renderers.\n- \/\/ In that case, if the source is mutated between the first and second renderer,\n- \/\/ The second renderer don't know that it needs to reset the WIP version during unwind,\n- \/\/ (because the hook only marks sources as dirty if it's written to their WIP version).\n- \/\/ That would cause this tear check to throw again and eventually be visible to the user.\n- \/\/ We can avoid this infinite loop by explicitly marking the source as dirty.\n- \/\/\n- \/\/ This can lead to tearing in the first renderer when it resumes,\n- \/\/ but there's nothing we can do about that (short of throwing here and refusing to continue the render).\n- markSourceAsDirty(source);\n-\n- \/\/ Intentioally throw an error to force React to retry synchronously. During\n- \/\/ the synchronous retry, it will block interleaved mutations, so we should\n- \/\/ get a consistent read. Therefore, the following error should never be\n- \/\/ visible to the user.\n- \/\/\n- \/\/ If it were to become visible to the user, it suggests one of two things:\n- \/\/ a bug in React, or (more likely), a mutation during the render phase that\n- \/\/ caused the second re-render attempt to be different from the first.\n- \/\/\n- \/\/ We know it's the second case if the logs are currently disabled. So in\n- \/\/ dev, we can present a more accurate error message.\n- if (__DEV__) {\n- \/\/ eslint-disable-next-line react-internal\/no-production-logging\n- if (getIsStrictModeForDevtools()) {\n- \/\/ If getIsStrictModeForDevtools is true, this is the dev-only double render\n- \/\/ This is only reachable if there was a mutation during render. Show a helpful\n- \/\/ error message.\n- \/\/\n- \/\/ Something interesting to note: because we only double render in\n- \/\/ development, this error will never happen during production. This is\n- \/\/ actually true of all errors that occur during a double render,\n- \/\/ because if the first render had thrown, we would have exited the\n- \/\/ begin phase without double rendering. We should consider suppressing\n- \/\/ any error from a double render (with a warning) to more closely match\n- \/\/ the production behavior.\n- const componentName = getComponentNameFromFiber(\n- currentlyRenderingFiber,\n- );\n- invariant(\n- false,\n- 'A mutable source was mutated while the %s component was rendering. ' +\n- 'This is not supported. Move any mutations into event handlers ' +\n- 'or effects.',\n- componentName,\n- );\n- }\n- }\n-\n- \/\/ We expect this error not to be thrown during the synchronous retry,\n- \/\/ because we blocked interleaved mutations.\n- invariant(\n- false,\n- 'Cannot read from mutable source during the current render without tearing. This may be a bug in React. Please file an issue.',\n- );\n- }\n-}\n-\n-function useMutableSource(\n- hook: Hook,\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n-): Snapshot {\n- const root = ((getWorkInProgressRoot(): any): FiberRoot);\n- invariant(\n- root !== null,\n- 'Expected a work-in-progress root. This is a bug in React. Please file an issue.',\n- );\n-\n- const getVersion = source._getVersion;\n- const version = getVersion(source._source);\n-\n- const dispatcher = ReactCurrentDispatcher.current;\n-\n- \/\/ eslint-disable-next-line prefer-const\n- let [currentSnapshot, setSnapshot] = dispatcher.useState(() =>\n- readFromUnsubscribedMutableSource(root, source, getSnapshot),\n- );\n- let snapshot = currentSnapshot;\n-\n- \/\/ Grab a handle to the state hook as well.\n- \/\/ We use it to clear the pending update queue if we have a new source.\n- const stateHook = ((workInProgressHook: any): Hook);\n-\n- const memoizedState = ((hook.memoizedState: any): MutableSourceMemoizedState<\n- Source,\n- Snapshot,\n- >);\n- const refs = memoizedState.refs;\n- const prevGetSnapshot = refs.getSnapshot;\n- const prevSource = memoizedState.source;\n- const prevSubscribe = memoizedState.subscribe;\n-\n- const fiber = currentlyRenderingFiber;\n-\n- hook.memoizedState = ({\n- refs,\n- source,\n- subscribe,\n- }: MutableSourceMemoizedState);\n-\n- \/\/ Sync the values needed by our subscription handler after each commit.\n- dispatcher.useEffect(() => {\n- refs.getSnapshot = getSnapshot;\n-\n- \/\/ Normally the dispatch function for a state hook never changes,\n- \/\/ but this hook recreates the queue in certain cases to avoid updates from stale sources.\n- \/\/ handleChange() below needs to reference the dispatch function without re-subscribing,\n- \/\/ so we use a ref to ensure that it always has the latest version.\n- refs.setSnapshot = setSnapshot;\n-\n- \/\/ Check for a possible change between when we last rendered now.\n- const maybeNewVersion = getVersion(source._source);\n- if (!is(version, maybeNewVersion)) {\n- const maybeNewSnapshot = getSnapshot(source._source);\n- if (__DEV__) {\n- if (typeof maybeNewSnapshot === 'function') {\n- console.error(\n- 'Mutable source should not return a function as the snapshot value. ' +\n- 'Functions may close over mutable values and cause tearing.',\n- );\n- }\n- }\n-\n- if (!is(snapshot, maybeNewSnapshot)) {\n- setSnapshot(maybeNewSnapshot);\n-\n- const lane = requestUpdateLane(fiber);\n- markRootMutableRead(root, lane);\n- }\n- \/\/ If the source mutated between render and now,\n- \/\/ there may be state updates already scheduled from the old source.\n- \/\/ Entangle the updates so that they render in the same batch.\n- markRootEntangled(root, root.mutableReadLanes);\n- }\n- }, [getSnapshot, source, subscribe]);\n-\n- \/\/ If we got a new source or subscribe function, re-subscribe in a passive effect.\n- dispatcher.useEffect(() => {\n- const handleChange = () => {\n- const latestGetSnapshot = refs.getSnapshot;\n- const latestSetSnapshot = refs.setSnapshot;\n-\n- try {\n- latestSetSnapshot(latestGetSnapshot(source._source));\n-\n- \/\/ Record a pending mutable source update with the same expiration time.\n- const lane = requestUpdateLane(fiber);\n-\n- markRootMutableRead(root, lane);\n- } catch (error) {\n- \/\/ A selector might throw after a source mutation.\n- \/\/ e.g. it might try to read from a part of the store that no longer exists.\n- \/\/ In this case we should still schedule an update with React.\n- \/\/ Worst case the selector will throw again and then an error boundary will handle it.\n- latestSetSnapshot(\n- (() => {\n- throw error;\n- }: any),\n- );\n- }\n- };\n-\n- const unsubscribe = subscribe(source._source, handleChange);\n- if (__DEV__) {\n- if (typeof unsubscribe !== 'function') {\n- console.error(\n- 'Mutable source subscribe function must return an unsubscribe function.',\n- );\n- }\n- }\n-\n- return unsubscribe;\n- }, [source, subscribe]);\n-\n- \/\/ If any of the inputs to useMutableSource change, reading is potentially unsafe.\n- \/\/\n- \/\/ If either the source or the subscription have changed we can't can't trust the update queue.\n- \/\/ Maybe the source changed in a way that the old subscription ignored but the new one depends on.\n- \/\/\n- \/\/ If the getSnapshot function changed, we also shouldn't rely on the update queue.\n- \/\/ It's possible that the underlying source was mutated between the when the last \"change\" event fired,\n- \/\/ and when the current render (with the new getSnapshot function) is processed.\n- \/\/\n- \/\/ In both cases, we need to throw away pending updates (since they are no longer relevant)\n- \/\/ and treat reading from the source as we do in the mount case.\n- if (\n- !is(prevGetSnapshot, getSnapshot) ||\n- !is(prevSource, source) ||\n- !is(prevSubscribe, subscribe)\n- ) {\n- \/\/ Create a new queue and setState method,\n- \/\/ So if there are interleaved updates, they get pushed to the older queue.\n- \/\/ When this becomes current, the previous queue and dispatch method will be discarded,\n- \/\/ including any interleaving updates that occur.\n- const newQueue: UpdateQueue> = {\n- pending: null,\n- interleaved: null,\n- lanes: NoLanes,\n- dispatch: null,\n- lastRenderedReducer: basicStateReducer,\n- lastRenderedState: snapshot,\n- };\n- newQueue.dispatch = setSnapshot = (dispatchAction.bind(\n- null,\n- currentlyRenderingFiber,\n- newQueue,\n- ): any);\n- stateHook.queue = newQueue;\n- stateHook.baseQueue = null;\n- snapshot = readFromUnsubscribedMutableSource(root, source, getSnapshot);\n- stateHook.memoizedState = stateHook.baseState = snapshot;\n- }\n-\n- return snapshot;\n-}\n-\n-function mountMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n-): Snapshot {\n- const hook = mountWorkInProgressHook();\n- hook.memoizedState = ({\n- refs: {\n- getSnapshot,\n- setSnapshot: (null: any),\n- },\n- source,\n- subscribe,\n- }: MutableSourceMemoizedState);\n- return useMutableSource(hook, source, getSnapshot, subscribe);\n-}\n-\n-function updateMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n-): Snapshot {\n- const hook = updateWorkInProgressHook();\n- return useMutableSource(hook, source, getSnapshot, subscribe);\n-}\n-\n function mountSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -2334,7 +2005,6 @@ export const ContextOnlyDispatcher: Dispatcher = {\n useDebugValue: throwInvalidHookError,\n useDeferredValue: throwInvalidHookError,\n useTransition: throwInvalidHookError,\n- useMutableSource: throwInvalidHookError,\n useSyncExternalStore: throwInvalidHookError,\n useOpaqueIdentifier: throwInvalidHookError,\n \n@@ -2361,7 +2031,6 @@ const HooksDispatcherOnMount: Dispatcher = {\n useDebugValue: mountDebugValue,\n useDeferredValue: mountDeferredValue,\n useTransition: mountTransition,\n- useMutableSource: mountMutableSource,\n useSyncExternalStore: mountSyncExternalStore,\n useOpaqueIdentifier: mountOpaqueIdentifier,\n \n@@ -2388,7 +2057,6 @@ const HooksDispatcherOnUpdate: Dispatcher = {\n useDebugValue: updateDebugValue,\n useDeferredValue: updateDeferredValue,\n useTransition: updateTransition,\n- useMutableSource: updateMutableSource,\n useSyncExternalStore: updateSyncExternalStore,\n useOpaqueIdentifier: updateOpaqueIdentifier,\n \n@@ -2415,7 +2083,6 @@ const HooksDispatcherOnRerender: Dispatcher = {\n useDebugValue: updateDebugValue,\n useDeferredValue: rerenderDeferredValue,\n useTransition: rerenderTransition,\n- useMutableSource: updateMutableSource,\n useSyncExternalStore: mountSyncExternalStore,\n useOpaqueIdentifier: rerenderOpaqueIdentifier,\n \n@@ -2565,15 +2232,6 @@ if (__DEV__) {\n mountHookTypesDev();\n return mountTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- mountHookTypesDev();\n- return mountMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -2705,15 +2363,6 @@ if (__DEV__) {\n updateHookTypesDev();\n return mountTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- updateHookTypesDev();\n- return mountMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -2845,15 +2494,6 @@ if (__DEV__) {\n updateHookTypesDev();\n return updateTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- updateHookTypesDev();\n- return updateMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -2986,15 +2626,6 @@ if (__DEV__) {\n updateHookTypesDev();\n return rerenderTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- updateHookTypesDev();\n- return updateMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -3140,16 +2771,6 @@ if (__DEV__) {\n mountHookTypesDev();\n return mountTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- warnInvalidHookAccess();\n- mountHookTypesDev();\n- return mountMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -3297,16 +2918,6 @@ if (__DEV__) {\n updateHookTypesDev();\n return updateTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- warnInvalidHookAccess();\n- updateHookTypesDev();\n- return updateMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -3455,16 +3066,6 @@ if (__DEV__) {\n updateHookTypesDev();\n return rerenderTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- warnInvalidHookAccess();\n- updateHookTypesDev();\n- return updateMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberHooks.old.js b\/packages\/react-reconciler\/src\/ReactFiberHooks.old.js\nindex a03dcd6ca2..016b208d30 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberHooks.old.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberHooks.old.js\n@@ -7,12 +7,7 @@\n * @flow\n *\/\n \n-import type {\n- MutableSource,\n- MutableSourceGetSnapshotFn,\n- MutableSourceSubscribeFn,\n- ReactContext,\n-} from 'shared\/ReactTypes';\n+import type {ReactContext} from 'shared\/ReactTypes';\n import type {Fiber, Dispatcher, HookType} from '.\/ReactInternalTypes';\n import type {Lanes, Lane} from '.\/ReactFiberLane.old';\n import type {HookFlags} from '.\/ReactHookEffectTags';\n@@ -50,7 +45,6 @@ import {\n intersectLanes,\n isTransitionLane,\n markRootEntangled,\n- markRootMutableRead,\n NoTimestamp,\n } from '.\/ReactFiberLane.old';\n import {\n@@ -102,12 +96,6 @@ import {\n makeClientIdInDEV,\n makeOpaqueHydratingObject,\n } from '.\/ReactFiberHostConfig';\n-import {\n- getWorkInProgressVersion,\n- markSourceAsDirty,\n- setWorkInProgressVersion,\n- warnAboutMultipleRenderersDEV,\n-} from '.\/ReactMutableSource.old';\n import {getIsRendering} from '.\/ReactCurrentFiber';\n import {logStateUpdateScheduled} from '.\/DebugTracing';\n import {markStateUpdateScheduled} from '.\/SchedulingProfiler';\n@@ -118,7 +106,6 @@ import {\n entangleTransitions,\n } from '.\/ReactUpdateQueue.old';\n import {pushInterleavedQueue} from '.\/ReactFiberInterleavedUpdates.old';\n-import {getIsStrictModeForDevtools} from '.\/ReactFiberReconciler.old';\n import {warnOnSubscriptionInsideStartTransition} from 'shared\/ReactFeatureFlags';\n \n const {ReactCurrentDispatcher, ReactCurrentBatchConfig} = ReactSharedInternals;\n@@ -948,322 +935,6 @@ function rerenderReducer(\n return [newState, dispatch];\n }\n \n-type MutableSourceMemoizedState = {|\n- refs: {\n- getSnapshot: MutableSourceGetSnapshotFn,\n- setSnapshot: Snapshot => void,\n- },\n- source: MutableSource,\n- subscribe: MutableSourceSubscribeFn,\n-|};\n-\n-function readFromUnsubscribedMutableSource(\n- root: FiberRoot,\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n-): Snapshot {\n- if (__DEV__) {\n- warnAboutMultipleRenderersDEV(source);\n- }\n-\n- const getVersion = source._getVersion;\n- const version = getVersion(source._source);\n-\n- \/\/ Is it safe for this component to read from this source during the current render?\n- let isSafeToReadFromSource = false;\n-\n- \/\/ Check the version first.\n- \/\/ If this render has already been started with a specific version,\n- \/\/ we can use it alone to determine if we can safely read from the source.\n- const currentRenderVersion = getWorkInProgressVersion(source);\n- if (currentRenderVersion !== null) {\n- \/\/ It's safe to read if the store hasn't been mutated since the last time\n- \/\/ we read something.\n- isSafeToReadFromSource = currentRenderVersion === version;\n- } else {\n- \/\/ If there's no version, then this is the first time we've read from the\n- \/\/ source during the current render pass, so we need to do a bit more work.\n- \/\/ What we need to determine is if there are any hooks that already\n- \/\/ subscribed to the source, and if so, whether there are any pending\n- \/\/ mutations that haven't been synchronized yet.\n- \/\/\n- \/\/ If there are no pending mutations, then `root.mutableReadLanes` will be\n- \/\/ empty, and we know we can safely read.\n- \/\/\n- \/\/ If there *are* pending mutations, we may still be able to safely read\n- \/\/ if the currently rendering lanes are inclusive of the pending mutation\n- \/\/ lanes, since that guarantees that the value we're about to read from\n- \/\/ the source is consistent with the values that we read during the most\n- \/\/ recent mutation.\n- isSafeToReadFromSource = isSubsetOfLanes(\n- renderLanes,\n- root.mutableReadLanes,\n- );\n-\n- if (isSafeToReadFromSource) {\n- \/\/ If it's safe to read from this source during the current render,\n- \/\/ store the version in case other components read from it.\n- \/\/ A changed version number will let those components know to throw and restart the render.\n- setWorkInProgressVersion(source, version);\n- }\n- }\n-\n- if (isSafeToReadFromSource) {\n- const snapshot = getSnapshot(source._source);\n- if (__DEV__) {\n- if (typeof snapshot === 'function') {\n- console.error(\n- 'Mutable source should not return a function as the snapshot value. ' +\n- 'Functions may close over mutable values and cause tearing.',\n- );\n- }\n- }\n- return snapshot;\n- } else {\n- \/\/ This handles the special case of a mutable source being shared between renderers.\n- \/\/ In that case, if the source is mutated between the first and second renderer,\n- \/\/ The second renderer don't know that it needs to reset the WIP version during unwind,\n- \/\/ (because the hook only marks sources as dirty if it's written to their WIP version).\n- \/\/ That would cause this tear check to throw again and eventually be visible to the user.\n- \/\/ We can avoid this infinite loop by explicitly marking the source as dirty.\n- \/\/\n- \/\/ This can lead to tearing in the first renderer when it resumes,\n- \/\/ but there's nothing we can do about that (short of throwing here and refusing to continue the render).\n- markSourceAsDirty(source);\n-\n- \/\/ Intentioally throw an error to force React to retry synchronously. During\n- \/\/ the synchronous retry, it will block interleaved mutations, so we should\n- \/\/ get a consistent read. Therefore, the following error should never be\n- \/\/ visible to the user.\n- \/\/\n- \/\/ If it were to become visible to the user, it suggests one of two things:\n- \/\/ a bug in React, or (more likely), a mutation during the render phase that\n- \/\/ caused the second re-render attempt to be different from the first.\n- \/\/\n- \/\/ We know it's the second case if the logs are currently disabled. So in\n- \/\/ dev, we can present a more accurate error message.\n- if (__DEV__) {\n- \/\/ eslint-disable-next-line react-internal\/no-production-logging\n- if (getIsStrictModeForDevtools()) {\n- \/\/ If getIsStrictModeForDevtools is true, this is the dev-only double render\n- \/\/ This is only reachable if there was a mutation during render. Show a helpful\n- \/\/ error message.\n- \/\/\n- \/\/ Something interesting to note: because we only double render in\n- \/\/ development, this error will never happen during production. This is\n- \/\/ actually true of all errors that occur during a double render,\n- \/\/ because if the first render had thrown, we would have exited the\n- \/\/ begin phase without double rendering. We should consider suppressing\n- \/\/ any error from a double render (with a warning) to more closely match\n- \/\/ the production behavior.\n- const componentName = getComponentNameFromFiber(\n- currentlyRenderingFiber,\n- );\n- invariant(\n- false,\n- 'A mutable source was mutated while the %s component was rendering. ' +\n- 'This is not supported. Move any mutations into event handlers ' +\n- 'or effects.',\n- componentName,\n- );\n- }\n- }\n-\n- \/\/ We expect this error not to be thrown during the synchronous retry,\n- \/\/ because we blocked interleaved mutations.\n- invariant(\n- false,\n- 'Cannot read from mutable source during the current render without tearing. This may be a bug in React. Please file an issue.',\n- );\n- }\n-}\n-\n-function useMutableSource(\n- hook: Hook,\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n-): Snapshot {\n- const root = ((getWorkInProgressRoot(): any): FiberRoot);\n- invariant(\n- root !== null,\n- 'Expected a work-in-progress root. This is a bug in React. Please file an issue.',\n- );\n-\n- const getVersion = source._getVersion;\n- const version = getVersion(source._source);\n-\n- const dispatcher = ReactCurrentDispatcher.current;\n-\n- \/\/ eslint-disable-next-line prefer-const\n- let [currentSnapshot, setSnapshot] = dispatcher.useState(() =>\n- readFromUnsubscribedMutableSource(root, source, getSnapshot),\n- );\n- let snapshot = currentSnapshot;\n-\n- \/\/ Grab a handle to the state hook as well.\n- \/\/ We use it to clear the pending update queue if we have a new source.\n- const stateHook = ((workInProgressHook: any): Hook);\n-\n- const memoizedState = ((hook.memoizedState: any): MutableSourceMemoizedState<\n- Source,\n- Snapshot,\n- >);\n- const refs = memoizedState.refs;\n- const prevGetSnapshot = refs.getSnapshot;\n- const prevSource = memoizedState.source;\n- const prevSubscribe = memoizedState.subscribe;\n-\n- const fiber = currentlyRenderingFiber;\n-\n- hook.memoizedState = ({\n- refs,\n- source,\n- subscribe,\n- }: MutableSourceMemoizedState);\n-\n- \/\/ Sync the values needed by our subscription handler after each commit.\n- dispatcher.useEffect(() => {\n- refs.getSnapshot = getSnapshot;\n-\n- \/\/ Normally the dispatch function for a state hook never changes,\n- \/\/ but this hook recreates the queue in certain cases to avoid updates from stale sources.\n- \/\/ handleChange() below needs to reference the dispatch function without re-subscribing,\n- \/\/ so we use a ref to ensure that it always has the latest version.\n- refs.setSnapshot = setSnapshot;\n-\n- \/\/ Check for a possible change between when we last rendered now.\n- const maybeNewVersion = getVersion(source._source);\n- if (!is(version, maybeNewVersion)) {\n- const maybeNewSnapshot = getSnapshot(source._source);\n- if (__DEV__) {\n- if (typeof maybeNewSnapshot === 'function') {\n- console.error(\n- 'Mutable source should not return a function as the snapshot value. ' +\n- 'Functions may close over mutable values and cause tearing.',\n- );\n- }\n- }\n-\n- if (!is(snapshot, maybeNewSnapshot)) {\n- setSnapshot(maybeNewSnapshot);\n-\n- const lane = requestUpdateLane(fiber);\n- markRootMutableRead(root, lane);\n- }\n- \/\/ If the source mutated between render and now,\n- \/\/ there may be state updates already scheduled from the old source.\n- \/\/ Entangle the updates so that they render in the same batch.\n- markRootEntangled(root, root.mutableReadLanes);\n- }\n- }, [getSnapshot, source, subscribe]);\n-\n- \/\/ If we got a new source or subscribe function, re-subscribe in a passive effect.\n- dispatcher.useEffect(() => {\n- const handleChange = () => {\n- const latestGetSnapshot = refs.getSnapshot;\n- const latestSetSnapshot = refs.setSnapshot;\n-\n- try {\n- latestSetSnapshot(latestGetSnapshot(source._source));\n-\n- \/\/ Record a pending mutable source update with the same expiration time.\n- const lane = requestUpdateLane(fiber);\n-\n- markRootMutableRead(root, lane);\n- } catch (error) {\n- \/\/ A selector might throw after a source mutation.\n- \/\/ e.g. it might try to read from a part of the store that no longer exists.\n- \/\/ In this case we should still schedule an update with React.\n- \/\/ Worst case the selector will throw again and then an error boundary will handle it.\n- latestSetSnapshot(\n- (() => {\n- throw error;\n- }: any),\n- );\n- }\n- };\n-\n- const unsubscribe = subscribe(source._source, handleChange);\n- if (__DEV__) {\n- if (typeof unsubscribe !== 'function') {\n- console.error(\n- 'Mutable source subscribe function must return an unsubscribe function.',\n- );\n- }\n- }\n-\n- return unsubscribe;\n- }, [source, subscribe]);\n-\n- \/\/ If any of the inputs to useMutableSource change, reading is potentially unsafe.\n- \/\/\n- \/\/ If either the source or the subscription have changed we can't can't trust the update queue.\n- \/\/ Maybe the source changed in a way that the old subscription ignored but the new one depends on.\n- \/\/\n- \/\/ If the getSnapshot function changed, we also shouldn't rely on the update queue.\n- \/\/ It's possible that the underlying source was mutated between the when the last \"change\" event fired,\n- \/\/ and when the current render (with the new getSnapshot function) is processed.\n- \/\/\n- \/\/ In both cases, we need to throw away pending updates (since they are no longer relevant)\n- \/\/ and treat reading from the source as we do in the mount case.\n- if (\n- !is(prevGetSnapshot, getSnapshot) ||\n- !is(prevSource, source) ||\n- !is(prevSubscribe, subscribe)\n- ) {\n- \/\/ Create a new queue and setState method,\n- \/\/ So if there are interleaved updates, they get pushed to the older queue.\n- \/\/ When this becomes current, the previous queue and dispatch method will be discarded,\n- \/\/ including any interleaving updates that occur.\n- const newQueue: UpdateQueue> = {\n- pending: null,\n- interleaved: null,\n- lanes: NoLanes,\n- dispatch: null,\n- lastRenderedReducer: basicStateReducer,\n- lastRenderedState: snapshot,\n- };\n- newQueue.dispatch = setSnapshot = (dispatchAction.bind(\n- null,\n- currentlyRenderingFiber,\n- newQueue,\n- ): any);\n- stateHook.queue = newQueue;\n- stateHook.baseQueue = null;\n- snapshot = readFromUnsubscribedMutableSource(root, source, getSnapshot);\n- stateHook.memoizedState = stateHook.baseState = snapshot;\n- }\n-\n- return snapshot;\n-}\n-\n-function mountMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n-): Snapshot {\n- const hook = mountWorkInProgressHook();\n- hook.memoizedState = ({\n- refs: {\n- getSnapshot,\n- setSnapshot: (null: any),\n- },\n- source,\n- subscribe,\n- }: MutableSourceMemoizedState);\n- return useMutableSource(hook, source, getSnapshot, subscribe);\n-}\n-\n-function updateMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n-): Snapshot {\n- const hook = updateWorkInProgressHook();\n- return useMutableSource(hook, source, getSnapshot, subscribe);\n-}\n-\n function mountSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -2334,7 +2005,6 @@ export const ContextOnlyDispatcher: Dispatcher = {\n useDebugValue: throwInvalidHookError,\n useDeferredValue: throwInvalidHookError,\n useTransition: throwInvalidHookError,\n- useMutableSource: throwInvalidHookError,\n useSyncExternalStore: throwInvalidHookError,\n useOpaqueIdentifier: throwInvalidHookError,\n \n@@ -2361,7 +2031,6 @@ const HooksDispatcherOnMount: Dispatcher = {\n useDebugValue: mountDebugValue,\n useDeferredValue: mountDeferredValue,\n useTransition: mountTransition,\n- useMutableSource: mountMutableSource,\n useSyncExternalStore: mountSyncExternalStore,\n useOpaqueIdentifier: mountOpaqueIdentifier,\n \n@@ -2388,7 +2057,6 @@ const HooksDispatcherOnUpdate: Dispatcher = {\n useDebugValue: updateDebugValue,\n useDeferredValue: updateDeferredValue,\n useTransition: updateTransition,\n- useMutableSource: updateMutableSource,\n useSyncExternalStore: updateSyncExternalStore,\n useOpaqueIdentifier: updateOpaqueIdentifier,\n \n@@ -2415,7 +2083,6 @@ const HooksDispatcherOnRerender: Dispatcher = {\n useDebugValue: updateDebugValue,\n useDeferredValue: rerenderDeferredValue,\n useTransition: rerenderTransition,\n- useMutableSource: updateMutableSource,\n useSyncExternalStore: mountSyncExternalStore,\n useOpaqueIdentifier: rerenderOpaqueIdentifier,\n \n@@ -2565,15 +2232,6 @@ if (__DEV__) {\n mountHookTypesDev();\n return mountTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- mountHookTypesDev();\n- return mountMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -2705,15 +2363,6 @@ if (__DEV__) {\n updateHookTypesDev();\n return mountTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- updateHookTypesDev();\n- return mountMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -2845,15 +2494,6 @@ if (__DEV__) {\n updateHookTypesDev();\n return updateTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- updateHookTypesDev();\n- return updateMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -2986,15 +2626,6 @@ if (__DEV__) {\n updateHookTypesDev();\n return rerenderTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- updateHookTypesDev();\n- return updateMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -3140,16 +2771,6 @@ if (__DEV__) {\n mountHookTypesDev();\n return mountTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- warnInvalidHookAccess();\n- mountHookTypesDev();\n- return mountMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -3297,16 +2918,6 @@ if (__DEV__) {\n updateHookTypesDev();\n return updateTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- warnInvalidHookAccess();\n- updateHookTypesDev();\n- return updateMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -3455,16 +3066,6 @@ if (__DEV__) {\n updateHookTypesDev();\n return rerenderTransition();\n },\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot {\n- currentHookNameInDev = 'useMutableSource';\n- warnInvalidHookAccess();\n- updateHookTypesDev();\n- return updateMutableSource(source, getSnapshot, subscribe);\n- },\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberLane.new.js b\/packages\/react-reconciler\/src\/ReactFiberLane.new.js\nindex ad124a432a..15d8e7ff01 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberLane.new.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberLane.new.js\n@@ -283,9 +283,9 @@ export function getNextLanes(root: FiberRoot, wipLanes: Lanes): Lanes {\n \/\/ time it takes to show the final state, which is what they are actually\n \/\/ waiting for.\n \/\/\n- \/\/ For those exceptions where entanglement is semantically important, like\n- \/\/ useMutableSource, we should ensure that there is no partial work at the\n- \/\/ time we apply the entanglement.\n+ \/\/ For those exceptions where entanglement is semantically important, we\n+ \/\/ should ensure that there is no partial work at the time we apply the\n+ \/\/ entanglement.\n const entangledLanes = root.entangledLanes;\n if (entangledLanes !== NoLanes) {\n const entanglements = root.entanglements;\n@@ -617,10 +617,6 @@ export function markRootPinged(\n root.pingedLanes |= root.suspendedLanes & pingedLanes;\n }\n \n-export function markRootMutableRead(root: FiberRoot, updateLane: Lane) {\n- root.mutableReadLanes |= updateLane & root.pendingLanes;\n-}\n-\n export function markRootFinished(root: FiberRoot, remainingLanes: Lanes) {\n const noLongerPendingLanes = root.pendingLanes & ~remainingLanes;\n \n@@ -631,7 +627,6 @@ export function markRootFinished(root: FiberRoot, remainingLanes: Lanes) {\n root.pingedLanes = 0;\n \n root.expiredLanes &= remainingLanes;\n- root.mutableReadLanes &= remainingLanes;\n \n root.entangledLanes &= remainingLanes;\n \ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberLane.old.js b\/packages\/react-reconciler\/src\/ReactFiberLane.old.js\nindex 4a064a3846..49927abb20 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberLane.old.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberLane.old.js\n@@ -283,9 +283,9 @@ export function getNextLanes(root: FiberRoot, wipLanes: Lanes): Lanes {\n \/\/ time it takes to show the final state, which is what they are actually\n \/\/ waiting for.\n \/\/\n- \/\/ For those exceptions where entanglement is semantically important, like\n- \/\/ useMutableSource, we should ensure that there is no partial work at the\n- \/\/ time we apply the entanglement.\n+ \/\/ For those exceptions where entanglement is semantically important, we\n+ \/\/ should ensure that there is no partial work at the time we apply the\n+ \/\/ entanglement.\n const entangledLanes = root.entangledLanes;\n if (entangledLanes !== NoLanes) {\n const entanglements = root.entanglements;\n@@ -617,10 +617,6 @@ export function markRootPinged(\n root.pingedLanes |= root.suspendedLanes & pingedLanes;\n }\n \n-export function markRootMutableRead(root: FiberRoot, updateLane: Lane) {\n- root.mutableReadLanes |= updateLane & root.pendingLanes;\n-}\n-\n export function markRootFinished(root: FiberRoot, remainingLanes: Lanes) {\n const noLongerPendingLanes = root.pendingLanes & ~remainingLanes;\n \n@@ -631,7 +627,6 @@ export function markRootFinished(root: FiberRoot, remainingLanes: Lanes) {\n root.pingedLanes = 0;\n \n root.expiredLanes &= remainingLanes;\n- root.mutableReadLanes &= remainingLanes;\n \n root.entangledLanes &= remainingLanes;\n \ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberReconciler.js b\/packages\/react-reconciler\/src\/ReactFiberReconciler.js\nindex 033b9eb0ad..ae029cd015 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberReconciler.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberReconciler.js\n@@ -46,7 +46,6 @@ import {\n findBoundingRects as findBoundingRects_old,\n focusWithin as focusWithin_old,\n observeVisibleRects as observeVisibleRects_old,\n- registerMutableSourceForHydration as registerMutableSourceForHydration_old,\n runWithPriority as runWithPriority_old,\n getCurrentUpdatePriority as getCurrentUpdatePriority_old,\n getIsStrictModeForDevtools as getIsStrictModeForDevtools_old,\n@@ -85,7 +84,6 @@ import {\n findBoundingRects as findBoundingRects_new,\n focusWithin as focusWithin_new,\n observeVisibleRects as observeVisibleRects_new,\n- registerMutableSourceForHydration as registerMutableSourceForHydration_new,\n runWithPriority as runWithPriority_new,\n getCurrentUpdatePriority as getCurrentUpdatePriority_new,\n getIsStrictModeForDevtools as getIsStrictModeForDevtools_new,\n@@ -188,9 +186,6 @@ export const focusWithin = enableNewReconciler\n export const observeVisibleRects = enableNewReconciler\n ? observeVisibleRects_new\n : observeVisibleRects_old;\n-export const registerMutableSourceForHydration = enableNewReconciler\n- ? registerMutableSourceForHydration_new\n- : registerMutableSourceForHydration_old;\n export const runWithPriority = enableNewReconciler\n ? runWithPriority_new\n : runWithPriority_old;\ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberReconciler.new.js b\/packages\/react-reconciler\/src\/ReactFiberReconciler.new.js\nindex 06acfa11cb..4219fdc72c 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberReconciler.new.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberReconciler.new.js\n@@ -93,7 +93,6 @@ import {\n } from '.\/ReactFiberHotReloading.new';\n import {markRenderScheduled} from '.\/SchedulingProfiler';\n import ReactVersion from 'shared\/ReactVersion';\n-export {registerMutableSourceForHydration} from '.\/ReactMutableSource.new';\n export {createPortal} from '.\/ReactPortal';\n export {\n createComponentSelector,\ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberReconciler.old.js b\/packages\/react-reconciler\/src\/ReactFiberReconciler.old.js\nindex 5a75a312c4..84bcb7e6e0 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberReconciler.old.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberReconciler.old.js\n@@ -93,7 +93,6 @@ import {\n } from '.\/ReactFiberHotReloading.old';\n import {markRenderScheduled} from '.\/SchedulingProfiler';\n import ReactVersion from 'shared\/ReactVersion';\n-export {registerMutableSourceForHydration} from '.\/ReactMutableSource.old';\n export {createPortal} from '.\/ReactPortal';\n export {\n createComponentSelector,\ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberRoot.new.js b\/packages\/react-reconciler\/src\/ReactFiberRoot.new.js\nindex 5e1f8275b6..d69d2d77e5 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberRoot.new.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberRoot.new.js\n@@ -49,7 +49,6 @@ function FiberRootNode(containerInfo, tag, hydrate) {\n this.suspendedLanes = NoLanes;\n this.pingedLanes = NoLanes;\n this.expiredLanes = NoLanes;\n- this.mutableReadLanes = NoLanes;\n this.finishedLanes = NoLanes;\n \n this.entangledLanes = NoLanes;\ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberRoot.old.js b\/packages\/react-reconciler\/src\/ReactFiberRoot.old.js\nindex 413a87fbcf..8469d6c85b 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberRoot.old.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberRoot.old.js\n@@ -49,7 +49,6 @@ function FiberRootNode(containerInfo, tag, hydrate) {\n this.suspendedLanes = NoLanes;\n this.pingedLanes = NoLanes;\n this.expiredLanes = NoLanes;\n- this.mutableReadLanes = NoLanes;\n this.finishedLanes = NoLanes;\n \n this.entangledLanes = NoLanes;\ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberUnwindWork.new.js b\/packages\/react-reconciler\/src\/ReactFiberUnwindWork.new.js\nindex 152837286f..cb0d90e1a7 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberUnwindWork.new.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberUnwindWork.new.js\n@@ -13,7 +13,6 @@ import type {Lanes} from '.\/ReactFiberLane.new';\n import type {SuspenseState} from '.\/ReactFiberSuspenseComponent.new';\n import type {Cache, SpawnedCachePool} from '.\/ReactFiberCacheComponent.new';\n \n-import {resetWorkInProgressVersions as resetMutableSourceWorkInProgressVersions} from '.\/ReactMutableSource.new';\n import {\n ClassComponent,\n HostRoot,\n@@ -83,7 +82,6 @@ function unwindWork(workInProgress: Fiber, renderLanes: Lanes) {\n }\n popHostContainer(workInProgress);\n popTopLevelLegacyContextObject(workInProgress);\n- resetMutableSourceWorkInProgressVersions();\n const flags = workInProgress.flags;\n invariant(\n (flags & DidCapture) === NoFlags,\n@@ -179,7 +177,6 @@ function unwindInterruptedWork(interruptedWork: Fiber, renderLanes: Lanes) {\n }\n popHostContainer(interruptedWork);\n popTopLevelLegacyContextObject(interruptedWork);\n- resetMutableSourceWorkInProgressVersions();\n break;\n }\n case HostComponent: {\ndiff --git a\/packages\/react-reconciler\/src\/ReactFiberUnwindWork.old.js b\/packages\/react-reconciler\/src\/ReactFiberUnwindWork.old.js\nindex 88861db778..8fb63177c0 100644\n--- a\/packages\/react-reconciler\/src\/ReactFiberUnwindWork.old.js\n+++ b\/packages\/react-reconciler\/src\/ReactFiberUnwindWork.old.js\n@@ -13,7 +13,6 @@ import type {Lanes} from '.\/ReactFiberLane.old';\n import type {SuspenseState} from '.\/ReactFiberSuspenseComponent.old';\n import type {Cache, SpawnedCachePool} from '.\/ReactFiberCacheComponent.old';\n \n-import {resetWorkInProgressVersions as resetMutableSourceWorkInProgressVersions} from '.\/ReactMutableSource.old';\n import {\n ClassComponent,\n HostRoot,\n@@ -83,7 +82,6 @@ function unwindWork(workInProgress: Fiber, renderLanes: Lanes) {\n }\n popHostContainer(workInProgress);\n popTopLevelLegacyContextObject(workInProgress);\n- resetMutableSourceWorkInProgressVersions();\n const flags = workInProgress.flags;\n invariant(\n (flags & DidCapture) === NoFlags,\n@@ -179,7 +177,6 @@ function unwindInterruptedWork(interruptedWork: Fiber, renderLanes: Lanes) {\n }\n popHostContainer(interruptedWork);\n popTopLevelLegacyContextObject(interruptedWork);\n- resetMutableSourceWorkInProgressVersions();\n break;\n }\n case HostComponent: {\ndiff --git a\/packages\/react-reconciler\/src\/ReactInternalTypes.js b\/packages\/react-reconciler\/src\/ReactInternalTypes.js\nindex f07fd4634b..692ec27bd7 100644\n--- a\/packages\/react-reconciler\/src\/ReactInternalTypes.js\n+++ b\/packages\/react-reconciler\/src\/ReactInternalTypes.js\n@@ -8,14 +8,7 @@\n *\/\n \n import type {Source} from 'shared\/ReactElementType';\n-import type {\n- RefObject,\n- ReactContext,\n- MutableSourceSubscribeFn,\n- MutableSourceGetSnapshotFn,\n- MutableSourceVersion,\n- MutableSource,\n-} from 'shared\/ReactTypes';\n+import type {RefObject, ReactContext} from 'shared\/ReactTypes';\n import type {SuspenseInstance} from '.\/ReactFiberHostConfig';\n import type {WorkTag} from '.\/ReactWorkTags';\n import type {TypeOfMode} from '.\/ReactTypeOfMode';\n@@ -41,7 +34,6 @@ export type HookType =\n | 'useDebugValue'\n | 'useDeferredValue'\n | 'useTransition'\n- | 'useMutableSource'\n | 'useSyncExternalStore'\n | 'useOpaqueIdentifier'\n | 'useCacheRefresh';\n@@ -214,11 +206,6 @@ type BaseFiberRootProperties = {|\n \/\/ Determines if we should attempt to hydrate on the initial mount\n +hydrate: boolean,\n \n- \/\/ Used by useMutableSource hook to avoid tearing during hydration.\n- mutableSourceEagerHydrationData?: Array<\n- MutableSource | MutableSourceVersion,\n- > | null,\n-\n \/\/ Node returned by Scheduler.scheduleCallback. Represents the next rendering\n \/\/ task that the root will work on.\n callbackNode: *,\n@@ -230,7 +217,6 @@ type BaseFiberRootProperties = {|\n suspendedLanes: Lanes,\n pingedLanes: Lanes,\n expiredLanes: Lanes,\n- mutableReadLanes: Lanes,\n \n finishedLanes: Lanes,\n \n@@ -305,11 +291,6 @@ export type Dispatcher = {|\n useDebugValue(value: T, formatterFn: ?(value: T) => mixed): void,\n useDeferredValue(value: T): T,\n useTransition(): [boolean, (() => void) => void],\n- useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n- ): Snapshot,\n useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\ndiff --git a\/packages\/react-reconciler\/src\/ReactMutableSource.new.js b\/packages\/react-reconciler\/src\/ReactMutableSource.new.js\ndeleted file mode 100644\nindex 61809d33f8..0000000000\n--- a\/packages\/react-reconciler\/src\/ReactMutableSource.new.js\n+++ \/dev\/null\n@@ -1,108 +0,0 @@\n-\/**\n- * Copyright (c) Facebook, Inc. and its affiliates.\n- *\n- * This source code is licensed under the MIT license found in the\n- * LICENSE file in the root directory of this source tree.\n- *\n- * @flow\n- *\/\n-\n-import type {MutableSource, MutableSourceVersion} from 'shared\/ReactTypes';\n-import type {FiberRoot} from '.\/ReactInternalTypes';\n-\n-import {isPrimaryRenderer} from '.\/ReactFiberHostConfig';\n-\n-\/\/ Work in progress version numbers only apply to a single render,\n-\/\/ and should be reset before starting a new render.\n-\/\/ This tracks which mutable sources need to be reset after a render.\n-const workInProgressSources: Array> = [];\n-\n-let rendererSigil;\n-if (__DEV__) {\n- \/\/ Used to detect multiple renderers using the same mutable source.\n- rendererSigil = {};\n-}\n-\n-export function markSourceAsDirty(mutableSource: MutableSource): void {\n- workInProgressSources.push(mutableSource);\n-}\n-\n-export function resetWorkInProgressVersions(): void {\n- for (let i = 0; i < workInProgressSources.length; i++) {\n- const mutableSource = workInProgressSources[i];\n- if (isPrimaryRenderer) {\n- mutableSource._workInProgressVersionPrimary = null;\n- } else {\n- mutableSource._workInProgressVersionSecondary = null;\n- }\n- }\n- workInProgressSources.length = 0;\n-}\n-\n-export function getWorkInProgressVersion(\n- mutableSource: MutableSource,\n-): null | MutableSourceVersion {\n- if (isPrimaryRenderer) {\n- return mutableSource._workInProgressVersionPrimary;\n- } else {\n- return mutableSource._workInProgressVersionSecondary;\n- }\n-}\n-\n-export function setWorkInProgressVersion(\n- mutableSource: MutableSource,\n- version: MutableSourceVersion,\n-): void {\n- if (isPrimaryRenderer) {\n- mutableSource._workInProgressVersionPrimary = version;\n- } else {\n- mutableSource._workInProgressVersionSecondary = version;\n- }\n- workInProgressSources.push(mutableSource);\n-}\n-\n-export function warnAboutMultipleRenderersDEV(\n- mutableSource: MutableSource,\n-): void {\n- if (__DEV__) {\n- if (isPrimaryRenderer) {\n- if (mutableSource._currentPrimaryRenderer == null) {\n- mutableSource._currentPrimaryRenderer = rendererSigil;\n- } else if (mutableSource._currentPrimaryRenderer !== rendererSigil) {\n- console.error(\n- 'Detected multiple renderers concurrently rendering the ' +\n- 'same mutable source. This is currently unsupported.',\n- );\n- }\n- } else {\n- if (mutableSource._currentSecondaryRenderer == null) {\n- mutableSource._currentSecondaryRenderer = rendererSigil;\n- } else if (mutableSource._currentSecondaryRenderer !== rendererSigil) {\n- console.error(\n- 'Detected multiple renderers concurrently rendering the ' +\n- 'same mutable source. This is currently unsupported.',\n- );\n- }\n- }\n- }\n-}\n-\n-\/\/ Eager reads the version of a mutable source and stores it on the root.\n-\/\/ This ensures that the version used for server rendering matches the one\n-\/\/ that is eventually read during hydration.\n-\/\/ If they don't match there's a potential tear and a full deopt render is required.\n-export function registerMutableSourceForHydration(\n- root: FiberRoot,\n- mutableSource: MutableSource,\n-): void {\n- const getVersion = mutableSource._getVersion;\n- const version = getVersion(mutableSource._source);\n-\n- \/\/ TODO Clear this data once all pending hydration work is finished.\n- \/\/ Retaining it forever may interfere with GC.\n- if (root.mutableSourceEagerHydrationData == null) {\n- root.mutableSourceEagerHydrationData = [mutableSource, version];\n- } else {\n- root.mutableSourceEagerHydrationData.push(mutableSource, version);\n- }\n-}\ndiff --git a\/packages\/react-reconciler\/src\/ReactMutableSource.old.js b\/packages\/react-reconciler\/src\/ReactMutableSource.old.js\ndeleted file mode 100644\nindex 61809d33f8..0000000000\n--- a\/packages\/react-reconciler\/src\/ReactMutableSource.old.js\n+++ \/dev\/null\n@@ -1,108 +0,0 @@\n-\/**\n- * Copyright (c) Facebook, Inc. and its affiliates.\n- *\n- * This source code is licensed under the MIT license found in the\n- * LICENSE file in the root directory of this source tree.\n- *\n- * @flow\n- *\/\n-\n-import type {MutableSource, MutableSourceVersion} from 'shared\/ReactTypes';\n-import type {FiberRoot} from '.\/ReactInternalTypes';\n-\n-import {isPrimaryRenderer} from '.\/ReactFiberHostConfig';\n-\n-\/\/ Work in progress version numbers only apply to a single render,\n-\/\/ and should be reset before starting a new render.\n-\/\/ This tracks which mutable sources need to be reset after a render.\n-const workInProgressSources: Array> = [];\n-\n-let rendererSigil;\n-if (__DEV__) {\n- \/\/ Used to detect multiple renderers using the same mutable source.\n- rendererSigil = {};\n-}\n-\n-export function markSourceAsDirty(mutableSource: MutableSource): void {\n- workInProgressSources.push(mutableSource);\n-}\n-\n-export function resetWorkInProgressVersions(): void {\n- for (let i = 0; i < workInProgressSources.length; i++) {\n- const mutableSource = workInProgressSources[i];\n- if (isPrimaryRenderer) {\n- mutableSource._workInProgressVersionPrimary = null;\n- } else {\n- mutableSource._workInProgressVersionSecondary = null;\n- }\n- }\n- workInProgressSources.length = 0;\n-}\n-\n-export function getWorkInProgressVersion(\n- mutableSource: MutableSource,\n-): null | MutableSourceVersion {\n- if (isPrimaryRenderer) {\n- return mutableSource._workInProgressVersionPrimary;\n- } else {\n- return mutableSource._workInProgressVersionSecondary;\n- }\n-}\n-\n-export function setWorkInProgressVersion(\n- mutableSource: MutableSource,\n- version: MutableSourceVersion,\n-): void {\n- if (isPrimaryRenderer) {\n- mutableSource._workInProgressVersionPrimary = version;\n- } else {\n- mutableSource._workInProgressVersionSecondary = version;\n- }\n- workInProgressSources.push(mutableSource);\n-}\n-\n-export function warnAboutMultipleRenderersDEV(\n- mutableSource: MutableSource,\n-): void {\n- if (__DEV__) {\n- if (isPrimaryRenderer) {\n- if (mutableSource._currentPrimaryRenderer == null) {\n- mutableSource._currentPrimaryRenderer = rendererSigil;\n- } else if (mutableSource._currentPrimaryRenderer !== rendererSigil) {\n- console.error(\n- 'Detected multiple renderers concurrently rendering the ' +\n- 'same mutable source. This is currently unsupported.',\n- );\n- }\n- } else {\n- if (mutableSource._currentSecondaryRenderer == null) {\n- mutableSource._currentSecondaryRenderer = rendererSigil;\n- } else if (mutableSource._currentSecondaryRenderer !== rendererSigil) {\n- console.error(\n- 'Detected multiple renderers concurrently rendering the ' +\n- 'same mutable source. This is currently unsupported.',\n- );\n- }\n- }\n- }\n-}\n-\n-\/\/ Eager reads the version of a mutable source and stores it on the root.\n-\/\/ This ensures that the version used for server rendering matches the one\n-\/\/ that is eventually read during hydration.\n-\/\/ If they don't match there's a potential tear and a full deopt render is required.\n-export function registerMutableSourceForHydration(\n- root: FiberRoot,\n- mutableSource: MutableSource,\n-): void {\n- const getVersion = mutableSource._getVersion;\n- const version = getVersion(mutableSource._source);\n-\n- \/\/ TODO Clear this data once all pending hydration work is finished.\n- \/\/ Retaining it forever may interfere with GC.\n- if (root.mutableSourceEagerHydrationData == null) {\n- root.mutableSourceEagerHydrationData = [mutableSource, version];\n- } else {\n- root.mutableSourceEagerHydrationData.push(mutableSource, version);\n- }\n-}\ndiff --git a\/packages\/react-reconciler\/src\/__tests__\/useMutableSource-test.internal.js b\/packages\/react-reconciler\/src\/__tests__\/useMutableSource-test.internal.js\ndeleted file mode 100644\nindex c9988b4fc2..0000000000\n--- a\/packages\/react-reconciler\/src\/__tests__\/useMutableSource-test.internal.js\n+++ \/dev\/null\n@@ -1,2098 +0,0 @@\n-\/**\n- * Copyright (c) Facebook, Inc. and its affiliates.\n- *\n- * This source code is licensed under the MIT license found in the\n- * LICENSE file in the root directory of this source tree.\n- *\n- * @emails react-core\n- * @jest-environment node\n- *\/\n-\n-\/* eslint-disable no-func-assign *\/\n-\n-'use strict';\n-\n-let React;\n-let ReactFeatureFlags;\n-let ReactNoop;\n-let Scheduler;\n-let act;\n-let createMutableSource;\n-let useMutableSource;\n-\n-function loadModules() {\n- jest.resetModules();\n- jest.useFakeTimers();\n-\n- ReactFeatureFlags = require('shared\/ReactFeatureFlags');\n- ReactFeatureFlags.enableProfilerTimer = true;\n-\n- React = require('react');\n- ReactNoop = require('react-noop-renderer');\n- Scheduler = require('scheduler');\n- act = require('jest-react').act;\n-\n- \/\/ Stable entrypoints export with \"unstable_\" prefix.\n- createMutableSource =\n- React.createMutableSource || React.unstable_createMutableSource;\n- useMutableSource = React.useMutableSource || React.unstable_useMutableSource;\n-}\n-\n-describe('useMutableSource', () => {\n- const defaultGetSnapshot = source => source.value;\n- const defaultSubscribe = (source, callback) => source.subscribe(callback);\n-\n- function createComplexSource(initialValueA, initialValueB) {\n- const callbacksA = [];\n- const callbacksB = [];\n- let revision = 0;\n- let valueA = initialValueA;\n- let valueB = initialValueB;\n-\n- const subscribeHelper = (callbacks, callback) => {\n- if (callbacks.indexOf(callback) < 0) {\n- callbacks.push(callback);\n- }\n- return () => {\n- const index = callbacks.indexOf(callback);\n- if (index >= 0) {\n- callbacks.splice(index, 1);\n- }\n- };\n- };\n-\n- return {\n- subscribeA(callback) {\n- return subscribeHelper(callbacksA, callback);\n- },\n- subscribeB(callback) {\n- return subscribeHelper(callbacksB, callback);\n- },\n-\n- get listenerCountA() {\n- return callbacksA.length;\n- },\n- get listenerCountB() {\n- return callbacksB.length;\n- },\n-\n- set valueA(newValue) {\n- revision++;\n- valueA = newValue;\n- callbacksA.forEach(callback => callback());\n- },\n- get valueA() {\n- return valueA;\n- },\n-\n- set valueB(newValue) {\n- revision++;\n- valueB = newValue;\n- callbacksB.forEach(callback => callback());\n- },\n- get valueB() {\n- return valueB;\n- },\n-\n- get version() {\n- return revision;\n- },\n- };\n- }\n-\n- function createSource(initialValue) {\n- const callbacks = [];\n- let revision = 0;\n- let value = initialValue;\n- return {\n- subscribe(callback) {\n- if (callbacks.indexOf(callback) < 0) {\n- callbacks.push(callback);\n- }\n- return () => {\n- const index = callbacks.indexOf(callback);\n- if (index >= 0) {\n- callbacks.splice(index, 1);\n- }\n- };\n- },\n- get listenerCount() {\n- return callbacks.length;\n- },\n- set value(newValue) {\n- revision++;\n- value = newValue;\n- callbacks.forEach(callback => callback());\n- },\n- get value() {\n- return value;\n- },\n- get version() {\n- return revision;\n- },\n- };\n- }\n-\n- function Component({getSnapshot, label, mutableSource, subscribe}) {\n- const snapshot = useMutableSource(mutableSource, getSnapshot, subscribe);\n- Scheduler.unstable_yieldValue(`${label}:${snapshot}`);\n- return

{`${label}:${snapshot}`}<\/div>;\n- }\n-\n- beforeEach(loadModules);\n-\n- it('should subscribe to a source and schedule updates when it changes', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- act(() => {\n- ReactNoop.renderToRootWithID(\n- <>\n- \n- \n- <\/>,\n- 'root',\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYieldThrough([\n- 'a:one',\n- 'b:one',\n- 'Sync effect',\n- ]);\n-\n- \/\/ Subscriptions should be passive\n- expect(source.listenerCount).toBe(0);\n- ReactNoop.flushPassiveEffects();\n- expect(source.listenerCount).toBe(2);\n-\n- \/\/ Changing values should schedule an update with React\n- source.value = 'two';\n- expect(Scheduler).toFlushAndYieldThrough(['a:two', 'b:two']);\n-\n- \/\/ Unmounting a component should remove its subscription.\n- ReactNoop.renderToRootWithID(\n- <>\n- \n- <\/>,\n- 'root',\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['a:two', 'Sync effect']);\n- ReactNoop.flushPassiveEffects();\n- expect(source.listenerCount).toBe(1);\n-\n- \/\/ Unmounting a root should remove the remaining event listeners\n- ReactNoop.unmountRootWithID('root');\n- expect(Scheduler).toFlushAndYield([]);\n- ReactNoop.flushPassiveEffects();\n- expect(source.listenerCount).toBe(0);\n-\n- \/\/ Changes to source should not trigger an updates or warnings.\n- source.value = 'three';\n- expect(Scheduler).toFlushAndYield([]);\n- });\n- });\n-\n- it('should restart work if a new source is mutated during render', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- act(() => {\n- if (gate(flags => flags.enableSyncDefaultUpdates)) {\n- React.startTransition(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- });\n- } else {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- }\n- \/\/ Do enough work to read from one component\n- expect(Scheduler).toFlushAndYieldThrough(['a:one']);\n-\n- \/\/ Mutate source before continuing work\n- source.value = 'two';\n-\n- \/\/ Render work should restart and the updated value should be used\n- expect(Scheduler).toFlushAndYield(['a:two', 'b:two', 'Sync effect']);\n- });\n- });\n-\n- it('should schedule an update if a new source is mutated between render and commit (subscription)', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- act(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n-\n- \/\/ Finish rendering\n- expect(Scheduler).toFlushAndYieldThrough([\n- 'a:one',\n- 'b:one',\n- 'Sync effect',\n- ]);\n-\n- \/\/ Mutate source before subscriptions are attached\n- expect(source.listenerCount).toBe(0);\n- source.value = 'two';\n-\n- \/\/ Mutation should be detected, and a new render should be scheduled\n- expect(Scheduler).toFlushAndYield(['a:two', 'b:two']);\n- });\n- });\n-\n- it('should unsubscribe and resubscribe if a new source is used', () => {\n- const sourceA = createSource('a-one');\n- const mutableSourceA = createMutableSource(\n- sourceA,\n- param => param.versionA,\n- );\n-\n- const sourceB = createSource('b-one');\n- const mutableSourceB = createMutableSource(\n- sourceB,\n- param => param.versionB,\n- );\n-\n- act(() => {\n- ReactNoop.render(\n- ,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['only:a-one', 'Sync effect']);\n- ReactNoop.flushPassiveEffects();\n- expect(sourceA.listenerCount).toBe(1);\n-\n- \/\/ Changing values should schedule an update with React\n- sourceA.value = 'a-two';\n- expect(Scheduler).toFlushAndYield(['only:a-two']);\n-\n- \/\/ If we re-render with a new source, the old one should be unsubscribed.\n- ReactNoop.render(\n- ,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['only:b-one', 'Sync effect']);\n- ReactNoop.flushPassiveEffects();\n- expect(sourceA.listenerCount).toBe(0);\n- expect(sourceB.listenerCount).toBe(1);\n-\n- \/\/ Changing to original source should not schedule updates with React\n- sourceA.value = 'a-three';\n- expect(Scheduler).toFlushAndYield([]);\n-\n- \/\/ Changing new source value should schedule an update with React\n- sourceB.value = 'b-two';\n- expect(Scheduler).toFlushAndYield(['only:b-two']);\n- });\n- });\n-\n- it('should unsubscribe and resubscribe if a new subscribe function is provided', () => {\n- const source = createSource('a-one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- const unsubscribeA = jest.fn();\n- const subscribeA = jest.fn(s => {\n- const unsubscribe = defaultSubscribe(s);\n- return () => {\n- unsubscribe();\n- unsubscribeA();\n- };\n- });\n- const unsubscribeB = jest.fn();\n- const subscribeB = jest.fn(s => {\n- const unsubscribe = defaultSubscribe(s);\n- return () => {\n- unsubscribe();\n- unsubscribeB();\n- };\n- });\n-\n- act(() => {\n- ReactNoop.renderToRootWithID(\n- ,\n- 'root',\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['only:a-one', 'Sync effect']);\n- ReactNoop.flushPassiveEffects();\n- expect(source.listenerCount).toBe(1);\n- expect(subscribeA).toHaveBeenCalledTimes(1);\n-\n- \/\/ If we re-render with a new subscription function,\n- \/\/ the old unsubscribe function should be called.\n- ReactNoop.renderToRootWithID(\n- ,\n- 'root',\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['only:a-one', 'Sync effect']);\n- ReactNoop.flushPassiveEffects();\n- expect(source.listenerCount).toBe(1);\n- expect(unsubscribeA).toHaveBeenCalledTimes(1);\n- expect(subscribeB).toHaveBeenCalledTimes(1);\n-\n- \/\/ Unmounting should call the newer unsubscribe.\n- ReactNoop.unmountRootWithID('root');\n- expect(Scheduler).toFlushAndYield([]);\n- ReactNoop.flushPassiveEffects();\n- expect(source.listenerCount).toBe(0);\n- expect(unsubscribeB).toHaveBeenCalledTimes(1);\n- });\n- });\n-\n- it('should re-use previously read snapshot value when reading is unsafe', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- act(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['a:one', 'b:one', 'Sync effect']);\n-\n- \/\/ Changing values should schedule an update with React.\n- \/\/ Start working on this update but don't finish it.\n- if (gate(flags => flags.enableSyncDefaultUpdates)) {\n- React.startTransition(() => {\n- source.value = 'two';\n- });\n- } else {\n- source.value = 'two';\n- }\n- expect(Scheduler).toFlushAndYieldThrough(['a:two']);\n-\n- \/\/ Re-renders that occur before the update is processed\n- \/\/ should reuse snapshot so long as the config has not changed\n- ReactNoop.flushSync(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- });\n- expect(Scheduler).toHaveYielded(['a:one', 'b:one', 'Sync effect']);\n-\n- expect(Scheduler).toFlushAndYield(['a:two', 'b:two']);\n- });\n- });\n-\n- it('should read from source on newly mounted subtree if no pending updates are scheduled for source', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- act(() => {\n- ReactNoop.render(\n- <>\n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['a:one', 'Sync effect']);\n-\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['a:one', 'b:one', 'Sync effect']);\n- });\n- });\n-\n- it('should throw and restart render if source and snapshot are unavailable during an update', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- act(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['a:one', 'b:one', 'Sync effect']);\n- ReactNoop.flushPassiveEffects();\n-\n- \/\/ Changing values should schedule an update with React.\n- \/\/ Start working on this update but don't finish it.\n- ReactNoop.idleUpdates(() => {\n- source.value = 'two';\n- expect(Scheduler).toFlushAndYieldThrough(['a:two']);\n- });\n-\n- const newGetSnapshot = s => 'new:' + defaultGetSnapshot(s);\n-\n- \/\/ Force a higher priority render with a new config.\n- \/\/ This should signal that the snapshot is not safe and trigger a full re-render.\n- ReactNoop.flushSync(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- });\n- expect(Scheduler).toHaveYielded([\n- 'a:new:two',\n- 'b:new:two',\n- 'Sync effect',\n- ]);\n- });\n- });\n-\n- it('should throw and restart render if source and snapshot are unavailable during a sync update', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- act(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['a:one', 'b:one', 'Sync effect']);\n- ReactNoop.flushPassiveEffects();\n-\n- \/\/ Changing values should schedule an update with React.\n- \/\/ Start working on this update but don't finish it.\n- ReactNoop.idleUpdates(() => {\n- source.value = 'two';\n- expect(Scheduler).toFlushAndYieldThrough(['a:two']);\n- });\n-\n- const newGetSnapshot = s => 'new:' + defaultGetSnapshot(s);\n-\n- \/\/ Force a higher priority render with a new config.\n- \/\/ This should signal that the snapshot is not safe and trigger a full re-render.\n- ReactNoop.flushSync(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- });\n- expect(Scheduler).toHaveYielded([\n- 'a:new:two',\n- 'b:new:two',\n- 'Sync effect',\n- ]);\n- });\n- });\n-\n- it('should only update components whose subscriptions fire', () => {\n- const source = createComplexSource('a:one', 'b:one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- \/\/ Subscribe to part of the store.\n- const getSnapshotA = s => s.valueA;\n- const subscribeA = (s, callback) => s.subscribeA(callback);\n- const getSnapshotB = s => s.valueB;\n- const subscribeB = (s, callback) => s.subscribeB(callback);\n-\n- act(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['a:a:one', 'b:b:one', 'Sync effect']);\n-\n- \/\/ Changes to part of the store (e.g. A) should not render other parts.\n- source.valueA = 'a:two';\n- expect(Scheduler).toFlushAndYield(['a:a:two']);\n- source.valueB = 'b:two';\n- expect(Scheduler).toFlushAndYield(['b:b:two']);\n- });\n- });\n-\n- it('should detect tearing in part of the store not yet subscribed to', () => {\n- const source = createComplexSource('a:one', 'b:one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- \/\/ Subscribe to part of the store.\n- const getSnapshotA = s => s.valueA;\n- const subscribeA = (s, callback) => s.subscribeA(callback);\n- const getSnapshotB = s => s.valueB;\n- const subscribeB = (s, callback) => s.subscribeB(callback);\n-\n- act(() => {\n- ReactNoop.render(\n- <>\n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['a:a:one', 'Sync effect']);\n-\n- \/\/ Because the store has not changed yet, there are no pending updates,\n- \/\/ so it is considered safe to read from when we start this render.\n- if (gate(flags => flags.enableSyncDefaultUpdates)) {\n- React.startTransition(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- });\n- } else {\n- ReactNoop.render(\n- <>\n- \n- \n- \n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- }\n- expect(Scheduler).toFlushAndYieldThrough(['a:a:one', 'b:b:one']);\n-\n- \/\/ Mutating the source should trigger a tear detection on the next read,\n- \/\/ which should throw and re-render the entire tree.\n- source.valueB = 'b:two';\n-\n- expect(Scheduler).toFlushAndYield([\n- 'a:a:one',\n- 'b:b:two',\n- 'c:b:two',\n- 'Sync effect',\n- ]);\n- });\n- });\n-\n- it('does not schedule an update for subscriptions that fire with an unchanged snapshot', () => {\n- const MockComponent = jest.fn(Component);\n-\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- act(() => {\n- ReactNoop.render(\n- ,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYieldThrough(['only:one', 'Sync effect']);\n- ReactNoop.flushPassiveEffects();\n- expect(source.listenerCount).toBe(1);\n-\n- \/\/ Notify subscribe function but don't change the value\n- source.value = 'one';\n- expect(Scheduler).toFlushWithoutYielding();\n- });\n- });\n-\n- it('should throw and restart if getSnapshot changes between scheduled update and re-render', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- const newGetSnapshot = s => 'new:' + defaultGetSnapshot(s);\n-\n- let updateGetSnapshot;\n-\n- function WrapperWithState() {\n- const tuple = React.useState(() => defaultGetSnapshot);\n- updateGetSnapshot = tuple[1];\n- return (\n- \n- );\n- }\n-\n- act(() => {\n- ReactNoop.render(, () =>\n- Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['only:one', 'Sync effect']);\n- ReactNoop.flushPassiveEffects();\n-\n- \/\/ Change the source (and schedule an update).\n- source.value = 'two';\n-\n- \/\/ Schedule a higher priority update that changes getSnapshot.\n- ReactNoop.flushSync(() => {\n- updateGetSnapshot(() => newGetSnapshot);\n- });\n-\n- expect(Scheduler).toHaveYielded(['only:new:two']);\n- });\n- });\n-\n- it('should recover from a mutation during yield when other work is scheduled', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- act(() => {\n- \/\/ Start a render that uses the mutable source.\n- if (gate(flags => flags.enableSyncDefaultUpdates)) {\n- React.startTransition(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- );\n- });\n- } else {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- );\n- }\n- expect(Scheduler).toFlushAndYieldThrough(['a:one']);\n-\n- \/\/ Mutate source\n- source.value = 'two';\n-\n- \/\/ Now render something different.\n- ReactNoop.render(

);\n- expect(Scheduler).toFlushAndYield([]);\n- });\n- });\n-\n- it('should not throw if the new getSnapshot returns the same snapshot value', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- const onRenderA = jest.fn();\n- const onRenderB = jest.fn();\n-\n- let updateGetSnapshot;\n-\n- function WrapperWithState() {\n- const tuple = React.useState(() => defaultGetSnapshot);\n- updateGetSnapshot = tuple[1];\n- return (\n- \n- );\n- }\n-\n- act(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/React.Profiler>\n- \n- \n- <\/React.Profiler>\n- <\/>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['a:one', 'b:one', 'Sync effect']);\n- ReactNoop.flushPassiveEffects();\n- expect(onRenderA).toHaveBeenCalledTimes(1);\n- expect(onRenderB).toHaveBeenCalledTimes(1);\n-\n- \/\/ If B's getSnapshot function updates, but the snapshot it returns is the same,\n- \/\/ only B should re-render (to update its state).\n- updateGetSnapshot(() => s => defaultGetSnapshot(s));\n- expect(Scheduler).toFlushAndYield(['b:one']);\n- ReactNoop.flushPassiveEffects();\n- expect(onRenderA).toHaveBeenCalledTimes(1);\n- expect(onRenderB).toHaveBeenCalledTimes(2);\n- });\n- });\n-\n- it('should not throw if getSnapshot changes but the source can be safely read from anyway', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- const newGetSnapshot = s => 'new:' + defaultGetSnapshot(s);\n-\n- let updateGetSnapshot;\n-\n- function WrapperWithState() {\n- const tuple = React.useState(() => defaultGetSnapshot);\n- updateGetSnapshot = tuple[1];\n- return (\n- \n- );\n- }\n-\n- act(() => {\n- ReactNoop.render(, () =>\n- Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['only:one', 'Sync effect']);\n- ReactNoop.flushPassiveEffects();\n-\n- \/\/ Change the source (and schedule an update)\n- \/\/ but also change the snapshot function too.\n- ReactNoop.batchedUpdates(() => {\n- source.value = 'two';\n- updateGetSnapshot(() => newGetSnapshot);\n- });\n-\n- expect(Scheduler).toFlushAndYield(['only:new:two']);\n- });\n- });\n-\n- it('should still schedule an update if an eager selector throws after a mutation', () => {\n- const source = createSource({\n- friends: [\n- {id: 1, name: 'Foo'},\n- {id: 2, name: 'Bar'},\n- ],\n- });\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- function FriendsList() {\n- const getSnapshot = React.useCallback(\n- ({value}) => Array.from(value.friends),\n- [],\n- );\n- const friends = useMutableSource(\n- mutableSource,\n- getSnapshot,\n- defaultSubscribe,\n- );\n- return (\n-

\n- ))}\n- <\/ul>\n- );\n- }\n-\n- function Friend({id}) {\n- const getSnapshot = React.useCallback(\n- ({value}) => {\n- \/\/ This selector is intentionally written in a way that will throw\n- \/\/ if no matching friend exists in the store.\n- return value.friends.find(friend => friend.id === id).name;\n- },\n- [id],\n- );\n- const name = useMutableSource(\n- mutableSource,\n- getSnapshot,\n- defaultSubscribe,\n- );\n- Scheduler.unstable_yieldValue(`${id}:${name}`);\n- return

{name}<\/li>;\n- }\n-\n- act(() => {\n- ReactNoop.render(, () =>\n- Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['1:Foo', '2:Bar', 'Sync effect']);\n-\n- \/\/ This mutation will cause the \"Bar\" component to throw,\n- \/\/ since its value will no longer be a part of the store.\n- \/\/ Mutable source should still schedule an update though,\n- \/\/ which should unmount \"Bar\" and mount \"Baz\".\n- source.value = {\n- friends: [\n- {id: 1, name: 'Foo'},\n- {id: 3, name: 'Baz'},\n- ],\n- };\n- expect(Scheduler).toFlushAndYield(['1:Foo', '3:Baz']);\n- });\n- });\n-\n- it('should not warn about updates that fire between unmount and passive unsubscribe', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- function Wrapper() {\n- React.useLayoutEffect(() => () => {\n- Scheduler.unstable_yieldValue('layout unmount');\n- });\n- return (\n- \n- );\n- }\n-\n- act(() => {\n- ReactNoop.renderToRootWithID(, 'root', () =>\n- Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYield(['only:one', 'Sync effect']);\n- ReactNoop.flushPassiveEffects();\n-\n- \/\/ Unmounting a root should remove the remaining event listeners in a passive effect\n- ReactNoop.unmountRootWithID('root');\n- expect(Scheduler).toFlushAndYieldThrough(['layout unmount']);\n-\n- \/\/ Changes to source should not cause a warning,\n- \/\/ even though the unsubscribe hasn't run yet (since it's a pending passive effect).\n- source.value = 'two';\n- expect(Scheduler).toFlushAndYield([]);\n- });\n- });\n-\n- it('should support inline selectors and updates that are processed after selector change', async () => {\n- const source = createSource({\n- a: 'initial',\n- b: 'initial',\n- });\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- const getSnapshotA = () => source.value.a;\n- const getSnapshotB = () => source.value.b;\n-\n- function mutateB(newB) {\n- source.value = {\n- ...source.value,\n- b: newB,\n- };\n- }\n-\n- function App({getSnapshot}) {\n- const state = useMutableSource(\n- mutableSource,\n- getSnapshot,\n- defaultSubscribe,\n- );\n- return state;\n- }\n-\n- const root = ReactNoop.createRoot();\n- await act(async () => {\n- root.render();\n- });\n- expect(root).toMatchRenderedOutput('initial');\n-\n- await act(async () => {\n- mutateB('Updated B');\n- root.render();\n- });\n- expect(root).toMatchRenderedOutput('Updated B');\n-\n- await act(async () => {\n- mutateB('Another update');\n- });\n- expect(root).toMatchRenderedOutput('Another update');\n- });\n-\n- it('should clear the update queue when getSnapshot changes with pending lower priority updates', async () => {\n- const source = createSource({\n- a: 'initial',\n- b: 'initial',\n- });\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- const getSnapshotA = () => source.value.a;\n- const getSnapshotB = () => source.value.b;\n-\n- function mutateA(newA) {\n- source.value = {\n- ...source.value,\n- a: newA,\n- };\n- }\n-\n- function mutateB(newB) {\n- source.value = {\n- ...source.value,\n- b: newB,\n- };\n- }\n-\n- function App({toggle}) {\n- const state = useMutableSource(\n- mutableSource,\n- toggle ? getSnapshotB : getSnapshotA,\n- defaultSubscribe,\n- );\n- const result = (toggle ? 'B: ' : 'A: ') + state;\n- return result;\n- }\n-\n- const root = ReactNoop.createRoot();\n- await act(async () => {\n- root.render();\n- });\n- expect(root).toMatchRenderedOutput('A: initial');\n-\n- await act(async () => {\n- ReactNoop.discreteUpdates(() => {\n- \/\/ Update both A and B to the same value\n- mutateA('Update');\n- mutateB('Update');\n- \/\/ Toggle to B in the same batch\n- root.render();\n- });\n- \/\/ Mutate A at lower priority. This should never be rendered, because\n- \/\/ by the time we get to the lower priority, we've already switched\n- \/\/ to B.\n- mutateA('OOPS! This mutation should be ignored');\n- });\n- expect(root).toMatchRenderedOutput('B: Update');\n- });\n-\n- it('should clear the update queue when source changes with pending lower priority updates', async () => {\n- const sourceA = createSource('initial');\n- const sourceB = createSource('initial');\n- const mutableSourceA = createMutableSource(\n- sourceA,\n- param => param.versionA,\n- );\n- const mutableSourceB = createMutableSource(\n- sourceB,\n- param => param.versionB,\n- );\n-\n- function App({toggle}) {\n- const state = useMutableSource(\n- toggle ? mutableSourceB : mutableSourceA,\n- defaultGetSnapshot,\n- defaultSubscribe,\n- );\n- const result = (toggle ? 'B: ' : 'A: ') + state;\n- return result;\n- }\n-\n- const root = ReactNoop.createRoot();\n- await act(async () => {\n- root.render();\n- });\n- expect(root).toMatchRenderedOutput('A: initial');\n-\n- await act(async () => {\n- ReactNoop.discreteUpdates(() => {\n- \/\/ Update both A and B to the same value\n- sourceA.value = 'Update';\n- sourceB.value = 'Update';\n- \/\/ Toggle to B in the same batch\n- root.render();\n- });\n- \/\/ Mutate A at lower priority. This should never be rendered, because\n- \/\/ by the time we get to the lower priority, we've already switched\n- \/\/ to B.\n- sourceA.value = 'OOPS! This mutation should be ignored';\n- });\n- expect(root).toMatchRenderedOutput('B: Update');\n- });\n-\n- it('should always treat reading as potentially unsafe when getSnapshot changes between renders', async () => {\n- const source = createSource({\n- a: 'foo',\n- b: 'bar',\n- });\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- const getSnapshotA = () => source.value.a;\n- const getSnapshotB = () => source.value.b;\n-\n- function mutateA(newA) {\n- source.value = {\n- ...source.value,\n- a: newA,\n- };\n- }\n-\n- function App({getSnapshotFirst, getSnapshotSecond}) {\n- const first = useMutableSource(\n- mutableSource,\n- getSnapshotFirst,\n- defaultSubscribe,\n- );\n- const second = useMutableSource(\n- mutableSource,\n- getSnapshotSecond,\n- defaultSubscribe,\n- );\n-\n- let result = `x: ${first}, y: ${second}`;\n-\n- if (getSnapshotFirst === getSnapshotSecond) {\n- \/\/ When both getSnapshot functions are equal,\n- \/\/ the two values must be consistent.\n- if (first !== second) {\n- result = 'Oops, tearing!';\n- }\n- }\n-\n- React.useEffect(() => {\n- Scheduler.unstable_yieldValue(result);\n- }, [result]);\n-\n- return result;\n- }\n-\n- const root = ReactNoop.createRoot();\n- await act(async () => {\n- root.render(\n- ,\n- );\n- });\n- \/\/ x and y start out reading from different parts of the store.\n- expect(Scheduler).toHaveYielded(['x: foo, y: bar']);\n-\n- await act(async () => {\n- ReactNoop.discreteUpdates(() => {\n- \/\/ At high priority, toggle y so that it reads from A instead of B.\n- \/\/ Simultaneously, mutate A.\n- mutateA('baz');\n- root.render(\n- ,\n- );\n-\n- \/\/ If this update were processed before the next mutation,\n- \/\/ it would be expected to yield \"baz\" and \"baz\".\n- });\n-\n- \/\/ At lower priority, mutate A again.\n- \/\/ This happens to match the initial value of B.\n- mutateA('bar');\n-\n- \/\/ When this update is processed,\n- \/\/ it is expected to yield \"bar\" and \"bar\".\n- });\n-\n- \/\/ Check that we didn't commit any inconsistent states.\n- \/\/ The actual sequence of work will be:\n- \/\/ 1. React renders the high-pri update, sees a new getSnapshot, detects the source has been further mutated, and throws\n- \/\/ 2. React re-renders with all pending updates, including the second mutation, and renders \"bar\" and \"bar\".\n- expect(Scheduler).toHaveYielded(['x: bar, y: bar']);\n- });\n-\n- it('getSnapshot changes and then source is mutated in between paint and passive effect phase', async () => {\n- const source = createSource({\n- a: 'foo',\n- b: 'bar',\n- });\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- function mutateB(newB) {\n- source.value = {\n- ...source.value,\n- b: newB,\n- };\n- }\n-\n- const getSnapshotA = () => source.value.a;\n- const getSnapshotB = () => source.value.b;\n-\n- function App({getSnapshot}) {\n- const value = useMutableSource(\n- mutableSource,\n- getSnapshot,\n- defaultSubscribe,\n- );\n-\n- Scheduler.unstable_yieldValue('Render: ' + value);\n- React.useEffect(() => {\n- Scheduler.unstable_yieldValue('Commit: ' + value);\n- }, [value]);\n-\n- return value;\n- }\n-\n- const root = ReactNoop.createRoot();\n- await act(async () => {\n- root.render();\n- });\n- expect(Scheduler).toHaveYielded(['Render: foo', 'Commit: foo']);\n-\n- await act(async () => {\n- \/\/ Switch getSnapshot to read from B instead\n- root.render();\n- \/\/ Render and finish the tree, but yield right after paint, before\n- \/\/ the passive effects have fired.\n- expect(Scheduler).toFlushUntilNextPaint(['Render: bar']);\n- \/\/ Then mutate B.\n- mutateB('baz');\n- });\n- expect(Scheduler).toHaveYielded([\n- \/\/ Fires the effect from the previous render\n- 'Commit: bar',\n- \/\/ During that effect, it should detect that the snapshot has changed\n- \/\/ and re-render.\n- 'Render: baz',\n- 'Commit: baz',\n- ]);\n- expect(root).toMatchRenderedOutput('baz');\n- });\n-\n- it('getSnapshot changes and then source is mutated in between paint and passive effect phase, case 2', async () => {\n- const source = createSource({\n- a: 'a0',\n- b: 'b0',\n- });\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- const getSnapshotA = () => source.value.a;\n- const getSnapshotB = () => source.value.b;\n-\n- function mutateA(newA) {\n- source.value = {\n- ...source.value,\n- a: newA,\n- };\n- }\n-\n- function App({getSnapshotFirst, getSnapshotSecond}) {\n- const first = useMutableSource(\n- mutableSource,\n- getSnapshotFirst,\n- defaultSubscribe,\n- );\n- const second = useMutableSource(\n- mutableSource,\n- getSnapshotSecond,\n- defaultSubscribe,\n- );\n-\n- return `first: ${first}, second: ${second}`;\n- }\n-\n- const root = ReactNoop.createRoot();\n- await act(async () => {\n- root.render(\n- ,\n- );\n- });\n- expect(root.getChildrenAsJSX()).toEqual('first: a0, second: b0');\n-\n- await act(async () => {\n- \/\/ Switch the second getSnapshot to also read from A\n- root.render(\n- ,\n- );\n- \/\/ Render and finish the tree, but yield right after paint, before\n- \/\/ the passive effects have fired.\n- expect(Scheduler).toFlushUntilNextPaint([]);\n-\n- \/\/ Now mutate A. Both hooks should update.\n- \/\/ This is at high priority so that it doesn't get batched with default\n- \/\/ priority updates that might fire during the passive effect\n- await act(async () => {\n- ReactNoop.discreteUpdates(() => {\n- mutateA('a1');\n- });\n- });\n-\n- expect(root).toMatchRenderedOutput('first: a1, second: a1');\n- });\n-\n- expect(root.getChildrenAsJSX()).toEqual('first: a1, second: a1');\n- });\n-\n- it(\n- 'if source is mutated after initial read but before subscription is set ' +\n- 'up, should still entangle all pending mutations even if snapshot of ' +\n- 'new subscription happens to match',\n- async () => {\n- const source = createSource({\n- a: 'a0',\n- b: 'b0',\n- });\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- const getSnapshotA = () => source.value.a;\n- const getSnapshotB = () => source.value.b;\n-\n- function mutateA(newA) {\n- source.value = {\n- ...source.value,\n- a: newA,\n- };\n- }\n-\n- function mutateB(newB) {\n- source.value = {\n- ...source.value,\n- b: newB,\n- };\n- }\n-\n- function Read({getSnapshot}) {\n- const value = useMutableSource(\n- mutableSource,\n- getSnapshot,\n- defaultSubscribe,\n- );\n- Scheduler.unstable_yieldValue(value);\n- return value;\n- }\n-\n- function Text({text}) {\n- Scheduler.unstable_yieldValue(text);\n- return text;\n- }\n-\n- const root = ReactNoop.createRoot();\n- await act(async () => {\n- root.render(\n- <>\n- \n- <\/>,\n- );\n- });\n- expect(Scheduler).toHaveYielded(['a0']);\n- expect(root).toMatchRenderedOutput('a0');\n-\n- await act(async () => {\n- if (gate(flags => flags.enableSyncDefaultUpdates)) {\n- React.startTransition(() => {\n- root.render(\n- <>\n- \n- \n- \n- <\/>,\n- );\n- });\n- } else {\n- root.render(\n- <>\n- \n- \n- \n- <\/>,\n- );\n- }\n-\n- expect(Scheduler).toFlushAndYieldThrough(['a0', 'b0']);\n- \/\/ Mutate in an event. This schedules a subscription update on a, which\n- \/\/ already mounted, but not b, which hasn't subscribed yet.\n- mutateA('a1');\n- mutateB('b1');\n-\n- \/\/ Mutate again at lower priority. This will schedule another subscription\n- \/\/ update on a, but not b. When b mounts and subscriptions, the value it\n- \/\/ read during render will happen to match the latest value. But it should\n- \/\/ still entangle the updates to prevent the previous update (a1) from\n- \/\/ rendering by itself.\n- React.startTransition(() => {\n- mutateA('a0');\n- mutateB('b0');\n- });\n- \/\/ Finish the current render\n- expect(Scheduler).toFlushUntilNextPaint(['c']);\n- \/\/ a0 will re-render because of the mutation update. But it should show\n- \/\/ the latest value, not the intermediate one, to avoid tearing with b.\n- expect(Scheduler).toFlushUntilNextPaint(['a0']);\n-\n- expect(root).toMatchRenderedOutput('a0b0c');\n- \/\/ We should be done.\n- expect(Scheduler).toFlushAndYield([]);\n- expect(root).toMatchRenderedOutput('a0b0c');\n- });\n- },\n- );\n-\n- it('warns about functions being used as snapshot values', async () => {\n- const source = createSource(() => 'a');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- const getSnapshot = () => source.value;\n-\n- function Read() {\n- const fn = useMutableSource(mutableSource, getSnapshot, defaultSubscribe);\n- const value = fn();\n- Scheduler.unstable_yieldValue(value);\n- return value;\n- }\n-\n- const root = ReactNoop.createRoot();\n- await act(async () => {\n- root.render(\n- <>\n- \n- <\/>,\n- );\n- expect(() => expect(Scheduler).toFlushAndYield(['a'])).toErrorDev(\n- 'Mutable source should not return a function as the snapshot value.',\n- );\n- });\n- expect(root).toMatchRenderedOutput('a');\n- });\n-\n- it('getSnapshot changes and then source is mutated during interleaved event', async () => {\n- const {useEffect} = React;\n-\n- const source = createComplexSource('1', '2');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- \/\/ Subscribe to part of the store.\n- const getSnapshotA = s => s.valueA;\n- const subscribeA = (s, callback) => s.subscribeA(callback);\n- const configA = [getSnapshotA, subscribeA];\n-\n- const getSnapshotB = s => s.valueB;\n- const subscribeB = (s, callback) => s.subscribeB(callback);\n- const configB = [getSnapshotB, subscribeB];\n-\n- function App({parentConfig, childConfig}) {\n- const [getSnapshot, subscribe] = parentConfig;\n- const parentValue = useMutableSource(\n- mutableSource,\n- getSnapshot,\n- subscribe,\n- );\n-\n- Scheduler.unstable_yieldValue('Parent: ' + parentValue);\n-\n- return (\n- \n- );\n- }\n-\n- function Child({parentConfig, childConfig, parentValue}) {\n- const [getSnapshot, subscribe] = childConfig;\n- const childValue = useMutableSource(\n- mutableSource,\n- getSnapshot,\n- subscribe,\n- );\n-\n- Scheduler.unstable_yieldValue('Child: ' + childValue);\n-\n- let result = `${parentValue}, ${childValue}`;\n-\n- if (parentConfig === childConfig) {\n- \/\/ When both components read using the same config, the two values\n- \/\/ must be consistent.\n- if (parentValue !== childValue) {\n- result = 'Oops, tearing!';\n- }\n- }\n-\n- useEffect(() => {\n- Scheduler.unstable_yieldValue('Commit: ' + result);\n- }, [result]);\n-\n- return result;\n- }\n-\n- const root = ReactNoop.createRoot();\n- await act(async () => {\n- root.render();\n- });\n- expect(Scheduler).toHaveYielded(['Parent: 1', 'Child: 2', 'Commit: 1, 2']);\n-\n- await act(async () => {\n- \/\/ Switch the parent and the child to read using the same config\n- if (gate(flags => flags.enableSyncDefaultUpdates)) {\n- React.startTransition(() => {\n- root.render();\n- });\n- } else {\n- root.render();\n- }\n- \/\/ Start rendering the parent, but yield before rendering the child\n- expect(Scheduler).toFlushAndYieldThrough(['Parent: 2']);\n-\n- \/\/ Mutate the config. This is at lower priority so that 1) to make sure\n- \/\/ it doesn't happen to get batched with the in-progress render, and 2)\n- \/\/ so it doesn't interrupt the in-progress render.\n- React.startTransition(() => {\n- source.valueB = '3';\n- });\n-\n- if (gate(flags => flags.enableSyncDefaultUpdates)) {\n- \/\/ In default sync mode, all of the updates flush sync.\n- expect(Scheduler).toFlushAndYieldThrough([\n- \/\/ The partial render completes\n- 'Child: 2',\n- 'Commit: 2, 2',\n- 'Parent: 3',\n- 'Child: 3',\n- ]);\n-\n- expect(Scheduler).toFlushAndYield([\n- \/\/ Now finish the rest of the update\n- 'Commit: 3, 3',\n- ]);\n- } else {\n- expect(Scheduler).toFlushAndYieldThrough([\n- \/\/ The partial render completes\n- 'Child: 2',\n- 'Commit: 2, 2',\n- ]);\n-\n- \/\/ Now there are two pending mutations at different priorities. But they\n- \/\/ both read the same version of the mutable source, so we must render\n- \/\/ them simultaneously.\n- \/\/\n- expect(Scheduler).toFlushAndYieldThrough([\n- 'Parent: 3',\n- \/\/ Demonstrates that we can yield here\n- ]);\n- expect(Scheduler).toFlushAndYield([\n- \/\/ Now finish the rest of the update\n- 'Child: 3',\n- 'Commit: 3, 3',\n- ]);\n- }\n- });\n- });\n-\n- it('should not tear with newly mounted component when updates were scheduled at a lower priority', async () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- let committedA = null;\n- let committedB = null;\n-\n- const onRender = () => {\n- if (committedB !== null) {\n- expect(committedA).toBe(committedB);\n- }\n- };\n-\n- function ComponentA() {\n- const snapshot = useMutableSource(\n- mutableSource,\n- defaultGetSnapshot,\n- defaultSubscribe,\n- );\n- Scheduler.unstable_yieldValue(`a:${snapshot}`);\n- React.useEffect(() => {\n- committedA = snapshot;\n- }, [snapshot]);\n- return

{`a:${snapshot}`}<\/div>;\n- }\n- function ComponentB() {\n- const snapshot = useMutableSource(\n- mutableSource,\n- defaultGetSnapshot,\n- defaultSubscribe,\n- );\n- Scheduler.unstable_yieldValue(`b:${snapshot}`);\n- React.useEffect(() => {\n- committedB = snapshot;\n- }, [snapshot]);\n- return

{`b:${snapshot}`}<\/div>;\n- }\n-\n- \/\/ Mount ComponentA with data version 1\n- act(() => {\n- ReactNoop.render(\n- \n- \n- <\/React.Profiler>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- });\n- expect(Scheduler).toHaveYielded(['a:one', 'Sync effect']);\n- expect(source.listenerCount).toBe(1);\n-\n- \/\/ Mount ComponentB with version 1 (but don't commit it)\n- act(() => {\n- ReactNoop.render(\n- \n- \n- \n- <\/React.Profiler>,\n- () => Scheduler.unstable_yieldValue('Sync effect'),\n- );\n- expect(Scheduler).toFlushAndYieldThrough([\n- 'a:one',\n- 'b:one',\n- 'Sync effect',\n- ]);\n- expect(source.listenerCount).toBe(1);\n-\n- \/\/ Mutate -> schedule update for ComponentA\n- React.startTransition(() => {\n- source.value = 'two';\n- });\n-\n- \/\/ Commit ComponentB -> notice the change and schedule an update for ComponentB\n- expect(Scheduler).toFlushAndYield(['a:two', 'b:two']);\n- expect(source.listenerCount).toBe(2);\n- });\n- });\n-\n- if (__DEV__) {\n- \/\/ See https:\/\/github.com\/facebook\/react\/issues\/19948\n- describe('side effects detection', () => {\n- it('should throw if a mutable source is mutated during render', () => {\n- const source = createSource(0);\n- const mutableSource = createMutableSource(\n- source,\n- param => param.version,\n- );\n-\n- let mutatedValueInRender = 1;\n- function MutateDuringRead() {\n- const value = useMutableSource(\n- mutableSource,\n- defaultGetSnapshot,\n- defaultSubscribe,\n- );\n- Scheduler.unstable_yieldValue('MutateDuringRead:' + value);\n- \/\/ Note that mutating an external value during render is a side effect and is not supported.\n- source.value = mutatedValueInRender++;\n- return null;\n- }\n-\n- \/\/ TODO The mechanism for this type of detection relies on StrictMode double rendering.\n- expect(() => {\n- act(() => {\n- ReactNoop.render(\n- \n- \n- <\/React.StrictMode>,\n- );\n- });\n- }).toThrow(\n- 'A mutable source was mutated while the MutateDuringRead component ' +\n- 'was rendering. This is not supported. Move any mutations into ' +\n- 'event handlers or effects.',\n- );\n-\n- expect(Scheduler).toHaveYielded([\n- \/\/ First attempt\n- 'MutateDuringRead:0',\n-\n- \/\/ Synchronous retry\n- 'MutateDuringRead:1',\n- ]);\n- });\n-\n- it('should throw if a mutable source is mutated during render (legacy mode)', () => {\n- const source = createSource('initial');\n- const mutableSource = createMutableSource(\n- source,\n- param => param.version,\n- );\n-\n- function MutateDuringRead() {\n- const value = useMutableSource(\n- mutableSource,\n- defaultGetSnapshot,\n- defaultSubscribe,\n- );\n- Scheduler.unstable_yieldValue('MutateDuringRead:' + value);\n- \/\/ Note that mutating an external value during render is a side effect and is not supported.\n- if (value === 'initial') {\n- source.value = 'updated';\n- }\n- return null;\n- }\n-\n- expect(() => {\n- act(() => {\n- ReactNoop.renderLegacySyncRoot(\n- \n- \n- <\/React.StrictMode>,\n- );\n- });\n- }).toThrow(\n- 'A mutable source was mutated while the MutateDuringRead component ' +\n- 'was rendering. This is not supported. Move any mutations into ' +\n- 'event handlers or effects.',\n- );\n-\n- expect(Scheduler).toHaveYielded(['MutateDuringRead:initial']);\n- });\n-\n- it('should not misidentify mutations after render as side effects', async () => {\n- const source = createSource('initial');\n- const mutableSource = createMutableSource(\n- source,\n- param => param.version,\n- );\n-\n- function MutateDuringRead() {\n- const value = useMutableSource(\n- mutableSource,\n- defaultGetSnapshot,\n- defaultSubscribe,\n- );\n- Scheduler.unstable_yieldValue('MutateDuringRead:' + value);\n- return null;\n- }\n-\n- await act(async () => {\n- ReactNoop.renderLegacySyncRoot(\n- \n- \n- <\/React.StrictMode>,\n- );\n- });\n- expect(Scheduler).toHaveYielded(['MutateDuringRead:initial']);\n-\n- await act(async () => {\n- source.value = 'updated';\n- });\n- expect(Scheduler).toHaveYielded(['MutateDuringRead:updated']);\n- });\n- });\n-\n- describe('dev warnings', () => {\n- it('should warn if the subscribe function does not return an unsubscribe function', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(\n- source,\n- param => param.version,\n- );\n-\n- const brokenSubscribe = () => {};\n-\n- expect(() => {\n- act(() => {\n- ReactNoop.render(\n- ,\n- );\n- });\n- }).toErrorDev(\n- 'Mutable source subscribe function must return an unsubscribe function.',\n- );\n- });\n-\n- it('should error if multiple renderers of the same type use a mutable source at the same time', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(\n- source,\n- param => param.version,\n- );\n-\n- act(() => {\n- \/\/ Start a render that uses the mutable source.\n- if (gate(flags => flags.enableSyncDefaultUpdates)) {\n- React.startTransition(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- );\n- });\n- } else {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- );\n- }\n- expect(Scheduler).toFlushAndYieldThrough(['a:one']);\n-\n- const PrevScheduler = Scheduler;\n-\n- \/\/ Get a new copy of ReactNoop.\n- loadModules();\n-\n- spyOnDev(console, 'error');\n-\n- \/\/ Use the mutablesource again but with a different renderer.\n- ReactNoop.render(\n- ,\n- );\n- expect(Scheduler).toFlushAndYieldThrough(['c:one']);\n-\n- expect(console.error.calls.argsFor(0)[0]).toContain(\n- 'Detected multiple renderers concurrently rendering the ' +\n- 'same mutable source. This is currently unsupported.',\n- );\n-\n- \/\/ TODO (useMutableSource) Act will automatically flush remaining work from render 1,\n- \/\/ but at this point something in the hooks dispatcher has been broken by jest.resetModules()\n- \/\/ Figure out what this is and remove this catch.\n- expect(() =>\n- PrevScheduler.unstable_flushAllWithoutAsserting(),\n- ).toThrow('Invalid hook call');\n- });\n- });\n-\n- it('should error if multiple renderers of the same type use a mutable source at the same time with mutation between', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(\n- source,\n- param => param.version,\n- );\n-\n- act(() => {\n- \/\/ Start a render that uses the mutable source.\n- if (gate(flags => flags.enableSyncDefaultUpdates)) {\n- React.startTransition(() => {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- );\n- });\n- } else {\n- ReactNoop.render(\n- <>\n- \n- \n- <\/>,\n- );\n- }\n- expect(Scheduler).toFlushAndYieldThrough(['a:one']);\n-\n- const PrevScheduler = Scheduler;\n-\n- \/\/ Get a new copy of ReactNoop.\n- loadModules();\n-\n- spyOnDev(console, 'error');\n-\n- \/\/ Mutate before the new render reads from the source.\n- source.value = 'two';\n-\n- \/\/ Use the mutablesource again but with a different renderer.\n- ReactNoop.render(\n- ,\n- );\n- expect(Scheduler).toFlushAndYieldThrough(['c:two']);\n-\n- expect(console.error.calls.argsFor(0)[0]).toContain(\n- 'Detected multiple renderers concurrently rendering the ' +\n- 'same mutable source. This is currently unsupported.',\n- );\n-\n- \/\/ TODO (useMutableSource) Act will automatically flush remaining work from render 1,\n- \/\/ but at this point something in the hooks dispatcher has been broken by jest.resetModules()\n- \/\/ Figure out what this is and remove this catch.\n- expect(() =>\n- PrevScheduler.unstable_flushAllWithoutAsserting(),\n- ).toThrow('Invalid hook call');\n- });\n- });\n- });\n- }\n-});\ndiff --git a\/packages\/react-reconciler\/src\/__tests__\/useMutableSourceHydration-test.js b\/packages\/react-reconciler\/src\/__tests__\/useMutableSourceHydration-test.js\ndeleted file mode 100644\nindex 7f46d1cb00..0000000000\n--- a\/packages\/react-reconciler\/src\/__tests__\/useMutableSourceHydration-test.js\n+++ \/dev\/null\n@@ -1,451 +0,0 @@\n-\/**\n- * Copyright (c) Facebook, Inc. and its affiliates.\n- *\n- * This source code is licensed under the MIT license found in the\n- * LICENSE file in the root directory of this source tree.\n- *\n- * @emails react-core\n- *\/\n-\n-'use strict';\n-\n-let React;\n-let ReactDOM;\n-let ReactDOMServer;\n-let Scheduler;\n-let act;\n-let createMutableSource;\n-let useMutableSource;\n-\n-describe('useMutableSourceHydration', () => {\n- beforeEach(() => {\n- jest.resetModules();\n-\n- React = require('react');\n- ReactDOM = require('react-dom');\n- ReactDOMServer = require('react-dom\/server');\n- Scheduler = require('scheduler');\n-\n- act = require('jest-react').act;\n-\n- \/\/ Stable entrypoints export with \"unstable_\" prefix.\n- createMutableSource =\n- React.createMutableSource || React.unstable_createMutableSource;\n- useMutableSource =\n- React.useMutableSource || React.unstable_useMutableSource;\n- });\n-\n- function dispatchAndSetCurrentEvent(el, event) {\n- try {\n- window.event = event;\n- el.dispatchEvent(event);\n- } finally {\n- window.event = undefined;\n- }\n- }\n-\n- const defaultGetSnapshot = source => source.value;\n- const defaultSubscribe = (source, callback) => source.subscribe(callback);\n-\n- function createComplexSource(initialValueA, initialValueB) {\n- const callbacksA = [];\n- const callbacksB = [];\n- let revision = 0;\n- let valueA = initialValueA;\n- let valueB = initialValueB;\n-\n- const subscribeHelper = (callbacks, callback) => {\n- if (callbacks.indexOf(callback) < 0) {\n- callbacks.push(callback);\n- }\n- return () => {\n- const index = callbacks.indexOf(callback);\n- if (index >= 0) {\n- callbacks.splice(index, 1);\n- }\n- };\n- };\n-\n- return {\n- subscribeA(callback) {\n- return subscribeHelper(callbacksA, callback);\n- },\n- subscribeB(callback) {\n- return subscribeHelper(callbacksB, callback);\n- },\n-\n- get listenerCountA() {\n- return callbacksA.length;\n- },\n- get listenerCountB() {\n- return callbacksB.length;\n- },\n-\n- set valueA(newValue) {\n- revision++;\n- valueA = newValue;\n- callbacksA.forEach(callback => callback());\n- },\n- get valueA() {\n- return valueA;\n- },\n-\n- set valueB(newValue) {\n- revision++;\n- valueB = newValue;\n- callbacksB.forEach(callback => callback());\n- },\n- get valueB() {\n- return valueB;\n- },\n-\n- get version() {\n- return revision;\n- },\n- };\n- }\n-\n- function createSource(initialValue) {\n- const callbacks = [];\n- let revision = 0;\n- let value = initialValue;\n- return {\n- subscribe(callback) {\n- if (callbacks.indexOf(callback) < 0) {\n- callbacks.push(callback);\n- }\n- return () => {\n- const index = callbacks.indexOf(callback);\n- if (index >= 0) {\n- callbacks.splice(index, 1);\n- }\n- };\n- },\n- get listenerCount() {\n- return callbacks.length;\n- },\n- set value(newValue) {\n- revision++;\n- value = newValue;\n- callbacks.forEach(callback => callback());\n- },\n- get value() {\n- return value;\n- },\n- get version() {\n- return revision;\n- },\n- };\n- }\n-\n- function Component({getSnapshot, label, mutableSource, subscribe}) {\n- const snapshot = useMutableSource(mutableSource, getSnapshot, subscribe);\n- Scheduler.unstable_yieldValue(`${label}:${snapshot}`);\n- return

{`${label}:${snapshot}`}<\/div>;\n- }\n-\n- it('should render and hydrate', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- function TestComponent() {\n- return (\n- \n- );\n- }\n-\n- const container = document.createElement('div');\n- document.body.appendChild(container);\n-\n- const htmlString = ReactDOMServer.renderToString();\n- container.innerHTML = htmlString;\n- expect(Scheduler).toHaveYielded(['only:one']);\n- expect(source.listenerCount).toBe(0);\n-\n- const root = ReactDOM.createRoot(container, {\n- hydrate: true,\n- hydrationOptions: {\n- mutableSources: [mutableSource],\n- },\n- });\n- act(() => {\n- root.render();\n- });\n- expect(Scheduler).toHaveYielded(['only:one']);\n- expect(source.listenerCount).toBe(1);\n- });\n-\n- it('should detect a tear before hydrating a component', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- function TestComponent() {\n- return (\n- \n- );\n- }\n-\n- const container = document.createElement('div');\n- document.body.appendChild(container);\n-\n- const htmlString = ReactDOMServer.renderToString();\n- container.innerHTML = htmlString;\n- expect(Scheduler).toHaveYielded(['only:one']);\n- expect(source.listenerCount).toBe(0);\n-\n- const root = ReactDOM.createRoot(container, {\n- hydrate: true,\n- hydrationOptions: {\n- mutableSources: [mutableSource],\n- },\n- });\n- expect(() => {\n- act(() => {\n- root.render();\n-\n- source.value = 'two';\n- });\n- }).toErrorDev(\n- 'Warning: An error occurred during hydration. ' +\n- 'The server HTML was replaced with client content in

.',\n- {withoutStack: true},\n- );\n- expect(Scheduler).toHaveYielded(['only:two']);\n- expect(source.listenerCount).toBe(1);\n- });\n-\n- it('should detect a tear between hydrating components', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- function TestComponent() {\n- return (\n- <>\n- \n- \n- <\/>\n- );\n- }\n-\n- const container = document.createElement('div');\n- document.body.appendChild(container);\n-\n- const htmlString = ReactDOMServer.renderToString();\n- container.innerHTML = htmlString;\n- expect(Scheduler).toHaveYielded(['a:one', 'b:one']);\n- expect(source.listenerCount).toBe(0);\n-\n- const root = ReactDOM.createRoot(container, {\n- hydrate: true,\n- hydrationOptions: {\n- mutableSources: [mutableSource],\n- },\n- });\n- expect(() => {\n- act(() => {\n- if (gate(flags => flags.enableSyncDefaultUpdates)) {\n- React.startTransition(() => {\n- root.render();\n- });\n- } else {\n- root.render();\n- }\n- expect(Scheduler).toFlushAndYieldThrough(['a:one']);\n- source.value = 'two';\n- });\n- }).toErrorDev(\n- 'Warning: An error occurred during hydration. ' +\n- 'The server HTML was replaced with client content in

.',\n- {withoutStack: true},\n- );\n- expect(Scheduler).toHaveYielded(['a:two', 'b:two']);\n- expect(source.listenerCount).toBe(2);\n- });\n-\n- it('should detect a tear between hydrating components reading from different parts of a source', () => {\n- const source = createComplexSource('a:one', 'b:one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- \/\/ Subscribe to part of the store.\n- const getSnapshotA = s => s.valueA;\n- const subscribeA = (s, callback) => s.subscribeA(callback);\n- const getSnapshotB = s => s.valueB;\n- const subscribeB = (s, callback) => s.subscribeB(callback);\n-\n- const container = document.createElement('div');\n- document.body.appendChild(container);\n-\n- const htmlString = ReactDOMServer.renderToString(\n- <>\n- \n- \n- <\/>,\n- );\n- container.innerHTML = htmlString;\n- expect(Scheduler).toHaveYielded(['0:a:one', '1:b:one']);\n-\n- const root = ReactDOM.createRoot(container, {\n- hydrate: true,\n- hydrationOptions: {\n- mutableSources: [mutableSource],\n- },\n- });\n- expect(() => {\n- act(() => {\n- if (gate(flags => flags.enableSyncDefaultUpdates)) {\n- React.startTransition(() => {\n- root.render(\n- <>\n- \n- \n- <\/>,\n- );\n- });\n- } else {\n- root.render(\n- <>\n- \n- \n- <\/>,\n- );\n- }\n- expect(Scheduler).toFlushAndYieldThrough(['0:a:one']);\n- source.valueB = 'b:two';\n- });\n- }).toErrorDev(\n- 'Warning: An error occurred during hydration. ' +\n- 'The server HTML was replaced with client content in

.',\n- {withoutStack: true},\n- );\n- expect(Scheduler).toHaveYielded(['0:a:one', '1:b:two']);\n- });\n-\n- \/\/ @gate !enableSyncDefaultUpdates\n- it('should detect a tear during a higher priority interruption', () => {\n- const source = createSource('one');\n- const mutableSource = createMutableSource(source, param => param.version);\n-\n- function Unrelated({flag}) {\n- Scheduler.unstable_yieldValue(flag);\n- return flag;\n- }\n-\n- function TestComponent({flag}) {\n- return (\n- <>\n- \n- \n- <\/>\n- );\n- }\n-\n- const container = document.createElement('div');\n- document.body.appendChild(container);\n-\n- const htmlString = ReactDOMServer.renderToString(\n- ,\n- );\n- container.innerHTML = htmlString;\n- expect(Scheduler).toHaveYielded([1, 'a:one']);\n- expect(source.listenerCount).toBe(0);\n-\n- const root = ReactDOM.createRoot(container, {\n- hydrate: true,\n- hydrationOptions: {\n- mutableSources: [mutableSource],\n- },\n- });\n-\n- expect(() => {\n- act(() => {\n- if (gate(flags => flags.enableSyncDefaultUpdates)) {\n- React.startTransition(() => {\n- root.render();\n- });\n- } else {\n- root.render();\n- }\n- expect(Scheduler).toFlushAndYieldThrough([1]);\n-\n- \/\/ Render an update which will be higher priority than the hydration.\n- \/\/ We can do this by scheduling the update inside a mouseover event.\n- const arbitraryElement = document.createElement('div');\n- const mouseOverEvent = document.createEvent('MouseEvents');\n- mouseOverEvent.initEvent('mouseover', true, true);\n- arbitraryElement.addEventListener('mouseover', () => {\n- root.render();\n- });\n- dispatchAndSetCurrentEvent(arbitraryElement, mouseOverEvent);\n-\n- expect(Scheduler).toFlushAndYieldThrough([2]);\n-\n- source.value = 'two';\n- });\n- }).toErrorDev(\n- [\n- 'Warning: An error occurred during hydration. ' +\n- 'The server HTML was replaced with client content in

.',\n-\n- 'Warning: Text content did not match. Server: \"1\" Client: \"2\"',\n- ],\n- {withoutStack: 1},\n- );\n- expect(Scheduler).toHaveYielded([2, 'a:two']);\n- expect(source.listenerCount).toBe(1);\n- });\n-});\ndiff --git a\/packages\/react-server\/src\/ReactFizzHooks.js b\/packages\/react-server\/src\/ReactFizzHooks.js\nindex 1618537ac1..c272ddbbb9 100644\n--- a\/packages\/react-server\/src\/ReactFizzHooks.js\n+++ b\/packages\/react-server\/src\/ReactFizzHooks.js\n@@ -9,12 +9,7 @@\n \n import type {Dispatcher as DispatcherType} from 'react-reconciler\/src\/ReactInternalTypes';\n \n-import type {\n- MutableSource,\n- MutableSourceGetSnapshotFn,\n- MutableSourceSubscribeFn,\n- ReactContext,\n-} from 'shared\/ReactTypes';\n+import type {ReactContext} from 'shared\/ReactTypes';\n \n import type {ResponseState, OpaqueIDType} from '.\/ReactServerFormatConfig';\n \n@@ -449,18 +444,6 @@ export function useCallback(\n return useMemo(() => callback, deps);\n }\n \n-\/\/ TODO Decide on how to implement this hook for server rendering.\n-\/\/ If a mutation occurs during render, consider triggering a Suspense boundary\n-\/\/ and falling back to client rendering.\n-function useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n-): Snapshot {\n- resolveCurrentlyRenderingComponent();\n- return getSnapshot(source._source);\n-}\n-\n function useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\n@@ -515,8 +498,6 @@ export const Dispatcher: DispatcherType = {\n useDeferredValue,\n useTransition,\n useOpaqueIdentifier,\n- \/\/ Subscriptions are not setup in a server environment.\n- useMutableSource,\n useSyncExternalStore,\n };\n \ndiff --git a\/packages\/react-server\/src\/ReactFlightServer.js b\/packages\/react-server\/src\/ReactFlightServer.js\nindex 5429d3a3b9..a555f7cac8 100644\n--- a\/packages\/react-server\/src\/ReactFlightServer.js\n+++ b\/packages\/react-server\/src\/ReactFlightServer.js\n@@ -827,7 +827,6 @@ const Dispatcher: DispatcherType = {\n useImperativeHandle: (unsupportedHook: any),\n useEffect: (unsupportedHook: any),\n useOpaqueIdentifier: (unsupportedHook: any),\n- useMutableSource: (unsupportedHook: any),\n useSyncExternalStore: (unsupportedHook: any),\n useCacheRefresh(): (?() => T, ?T) => void {\n return unsupportedRefresh;\ndiff --git a\/packages\/react-suspense-test-utils\/src\/ReactSuspenseTestUtils.js b\/packages\/react-suspense-test-utils\/src\/ReactSuspenseTestUtils.js\nindex b4b57c68b5..e4c886dc85 100644\n--- a\/packages\/react-suspense-test-utils\/src\/ReactSuspenseTestUtils.js\n+++ b\/packages\/react-suspense-test-utils\/src\/ReactSuspenseTestUtils.js\n@@ -44,7 +44,6 @@ export function waitForSuspense(fn: () => T): Promise {\n useDeferredValue: unsupported,\n useTransition: unsupported,\n useOpaqueIdentifier: unsupported,\n- useMutableSource: unsupported,\n useSyncExternalStore: unsupported,\n useCacheRefresh: unsupported,\n };\ndiff --git a\/packages\/react\/index.classic.fb.js b\/packages\/react\/index.classic.fb.js\nindex 7f8abc8631..d3ebdb5c02 100644\n--- a\/packages\/react\/index.classic.fb.js\n+++ b\/packages\/react\/index.classic.fb.js\n@@ -23,8 +23,6 @@ export {\n createContext,\n createElement,\n createFactory,\n- createMutableSource,\n- createMutableSource as unstable_createMutableSource,\n createRef,\n forwardRef,\n isValidElement,\n@@ -50,8 +48,6 @@ export {\n useLayoutEffect,\n unstable_useInsertionEffect,\n useMemo,\n- useMutableSource,\n- useMutableSource as unstable_useMutableSource,\n useSyncExternalStore,\n useSyncExternalStore as unstable_useSyncExternalStore,\n useReducer,\ndiff --git a\/packages\/react\/index.experimental.js b\/packages\/react\/index.experimental.js\nindex a0a9bbaca2..7ff629fd0a 100644\n--- a\/packages\/react\/index.experimental.js\n+++ b\/packages\/react\/index.experimental.js\n@@ -22,7 +22,6 @@ export {\n createContext,\n createElement,\n createFactory,\n- createMutableSource as unstable_createMutableSource,\n createRef,\n forwardRef,\n isValidElement,\n@@ -45,7 +44,6 @@ export {\n unstable_useInsertionEffect,\n useLayoutEffect,\n useMemo,\n- useMutableSource as unstable_useMutableSource,\n useSyncExternalStore as unstable_useSyncExternalStore,\n useReducer,\n useRef,\ndiff --git a\/packages\/react\/index.js b\/packages\/react\/index.js\nindex 1b4552a90f..17916a322b 100644\n--- a\/packages\/react\/index.js\n+++ b\/packages\/react\/index.js\n@@ -46,7 +46,6 @@ export {\n createContext,\n createElement,\n createFactory,\n- createMutableSource,\n createRef,\n forwardRef,\n isValidElement,\n@@ -70,7 +69,6 @@ export {\n unstable_useInsertionEffect,\n useLayoutEffect,\n useMemo,\n- useMutableSource,\n useSyncExternalStore,\n useSyncExternalStore as unstable_useSyncExternalStore,\n useReducer,\ndiff --git a\/packages\/react\/index.modern.fb.js b\/packages\/react\/index.modern.fb.js\nindex 819d5fe90a..e2a55bbdab 100644\n--- a\/packages\/react\/index.modern.fb.js\n+++ b\/packages\/react\/index.modern.fb.js\n@@ -22,8 +22,6 @@ export {\n cloneElement,\n createContext,\n createElement,\n- createMutableSource,\n- createMutableSource as unstable_createMutableSource,\n createRef,\n forwardRef,\n isValidElement,\n@@ -49,8 +47,6 @@ export {\n unstable_useInsertionEffect,\n useLayoutEffect,\n useMemo,\n- useMutableSource,\n- useMutableSource as unstable_useMutableSource,\n useSyncExternalStore,\n useSyncExternalStore as unstable_useSyncExternalStore,\n useReducer,\ndiff --git a\/packages\/react\/index.stable.js b\/packages\/react\/index.stable.js\nindex 008875e457..70ede828c8 100644\n--- a\/packages\/react\/index.stable.js\n+++ b\/packages\/react\/index.stable.js\n@@ -22,7 +22,6 @@ export {\n createContext,\n createElement,\n createFactory,\n- createMutableSource as unstable_createMutableSource,\n createRef,\n forwardRef,\n isValidElement,\n@@ -38,7 +37,6 @@ export {\n useImperativeHandle,\n useLayoutEffect,\n useMemo,\n- useMutableSource as unstable_useMutableSource,\n useReducer,\n useRef,\n useState,\ndiff --git a\/packages\/react\/src\/React.js b\/packages\/react\/src\/React.js\nindex 541e7a35d3..a171d16b8a 100644\n--- a\/packages\/react\/src\/React.js\n+++ b\/packages\/react\/src\/React.js\n@@ -44,7 +44,6 @@ import {\n useInsertionEffect,\n useLayoutEffect,\n useMemo,\n- useMutableSource,\n useSyncExternalStore,\n useReducer,\n useRef,\n@@ -59,7 +58,6 @@ import {\n createFactoryWithValidation,\n cloneElementWithValidation,\n } from '.\/ReactElementValidator';\n-import {createMutableSource} from '.\/ReactMutableSource';\n import ReactSharedInternals from '.\/ReactSharedInternals';\n import {startTransition} from '.\/ReactStartTransition';\n import {act} from '.\/ReactAct';\n@@ -79,7 +77,6 @@ const Children = {\n \n export {\n Children,\n- createMutableSource,\n createRef,\n Component,\n PureComponent,\n@@ -95,7 +92,6 @@ export {\n useInsertionEffect as unstable_useInsertionEffect,\n useLayoutEffect,\n useMemo,\n- useMutableSource,\n useSyncExternalStore,\n useReducer,\n useRef,\ndiff --git a\/packages\/react\/src\/ReactHooks.js b\/packages\/react\/src\/ReactHooks.js\nindex 0722cf4b20..77dbd53c9c 100644\n--- a\/packages\/react\/src\/ReactHooks.js\n+++ b\/packages\/react\/src\/ReactHooks.js\n@@ -8,12 +8,7 @@\n *\/\n \n import type {Dispatcher} from 'react-reconciler\/src\/ReactInternalTypes';\n-import type {\n- MutableSource,\n- MutableSourceGetSnapshotFn,\n- MutableSourceSubscribeFn,\n- ReactContext,\n-} from 'shared\/ReactTypes';\n+import type {ReactContext} from 'shared\/ReactTypes';\n import type {OpaqueIDType} from 'react-reconciler\/src\/ReactFiberHostConfig';\n \n import ReactCurrentDispatcher from '.\/ReactCurrentDispatcher';\n@@ -168,15 +163,6 @@ export function useOpaqueIdentifier(): OpaqueIDType | void {\n return dispatcher.useOpaqueIdentifier();\n }\n \n-export function useMutableSource(\n- source: MutableSource,\n- getSnapshot: MutableSourceGetSnapshotFn,\n- subscribe: MutableSourceSubscribeFn,\n-): Snapshot {\n- const dispatcher = resolveDispatcher();\n- return dispatcher.useMutableSource(source, getSnapshot, subscribe);\n-}\n-\n export function useSyncExternalStore(\n subscribe: (() => void) => () => void,\n getSnapshot: () => T,\ndiff --git a\/packages\/react\/src\/ReactMutableSource.js b\/packages\/react\/src\/ReactMutableSource.js\ndeleted file mode 100644\nindex f8e5d0b283..0000000000\n--- a\/packages\/react\/src\/ReactMutableSource.js\n+++ \/dev\/null\n@@ -1,34 +0,0 @@\n-\/**\n- * Copyright (c) Facebook, Inc. and its affiliates.\n- *\n- * This source code is licensed under the MIT license found in the\n- * LICENSE file in the root directory of this source tree.\n- *\n- * @flow\n- *\/\n-\n-import type {MutableSource, MutableSourceGetVersionFn} from 'shared\/ReactTypes';\n-\n-export function createMutableSource>(\n- source: Source,\n- getVersion: MutableSourceGetVersionFn,\n-): MutableSource {\n- const mutableSource: MutableSource = {\n- _getVersion: getVersion,\n- _source: source,\n- _workInProgressVersionPrimary: null,\n- _workInProgressVersionSecondary: null,\n- };\n-\n- if (__DEV__) {\n- mutableSource._currentPrimaryRenderer = null;\n- mutableSource._currentSecondaryRenderer = null;\n-\n- \/\/ Used to detect side effects that update a mutable source during render.\n- \/\/ See https:\/\/github.com\/facebook\/react\/issues\/19948\n- mutableSource._currentlyRenderingFiber = null;\n- mutableSource._initialVersionAsOfFirstRender = null;\n- }\n-\n- return mutableSource;\n-}\ndiff --git a\/packages\/react\/unstable-shared-subset.experimental.js b\/packages\/react\/unstable-shared-subset.experimental.js\nindex 9381778b44..c18138226a 100644\n--- a\/packages\/react\/unstable-shared-subset.experimental.js\n+++ b\/packages\/react\/unstable-shared-subset.experimental.js\n@@ -17,7 +17,6 @@ export {\n SuspenseList,\n cloneElement,\n createElement,\n- createMutableSource as unstable_createMutableSource,\n createRef,\n forwardRef,\n isValidElement,\n@@ -33,7 +32,6 @@ export {\n useDeferredValue,\n useDeferredValue as unstable_useDeferredValue,\n useMemo,\n- useMutableSource as unstable_useMutableSource,\n useTransition,\n version,\n } from '.\/src\/React';\ndiff --git a\/packages\/shared\/ReactTypes.js b\/packages\/shared\/ReactTypes.js\nindex 43f42bddb9..277f633387 100644\n--- a\/packages\/shared\/ReactTypes.js\n+++ b\/packages\/shared\/ReactTypes.js\n@@ -101,56 +101,6 @@ export type ReactScopeInstance = {|\n getChildContextValues: (context: ReactContext) => Array,\n |};\n \n-\/\/ Mutable source version can be anything (e.g. number, string, immutable data structure)\n-\/\/ so long as it changes every time any part of the source changes.\n-export type MutableSourceVersion = $NonMaybeType;\n-\n-export type MutableSourceGetSnapshotFn<\n- Source: $NonMaybeType,\n- Snapshot,\n-> = (source: Source) => Snapshot;\n-\n-export type MutableSourceSubscribeFn, Snapshot> = (\n- source: Source,\n- callback: (snapshot: Snapshot) => void,\n-) => () => void;\n-\n-export type MutableSourceGetVersionFn = (\n- source: $NonMaybeType,\n-) => MutableSourceVersion;\n-\n-export type MutableSource> = {|\n- _source: Source,\n-\n- _getVersion: MutableSourceGetVersionFn,\n-\n- \/\/ Tracks the version of this source at the time it was most recently read.\n- \/\/ Used to determine if a source is safe to read from before it has been subscribed to.\n- \/\/ Version number is only used during mount,\n- \/\/ since the mechanism for determining safety after subscription is expiration time.\n- \/\/\n- \/\/ As a workaround to support multiple concurrent renderers,\n- \/\/ we categorize some renderers as primary and others as secondary.\n- \/\/ We only expect there to be two concurrent renderers at most:\n- \/\/ React Native (primary) and Fabric (secondary);\n- \/\/ React DOM (primary) and React ART (secondary).\n- \/\/ Secondary renderers store their context values on separate fields.\n- \/\/ We use the same approach for Context.\n- _workInProgressVersionPrimary: null | MutableSourceVersion,\n- _workInProgressVersionSecondary: null | MutableSourceVersion,\n-\n- \/\/ DEV only\n- \/\/ Used to detect multiple renderers using the same mutable source.\n- _currentPrimaryRenderer?: Object | null,\n- _currentSecondaryRenderer?: Object | null,\n-\n- \/\/ DEV only\n- \/\/ Used to detect side effects that update a mutable source during render.\n- \/\/ See https:\/\/github.com\/facebook\/react\/issues\/19948\n- _currentlyRenderingFiber?: Fiber | null,\n- _initialVersionAsOfFirstRender?: MutableSourceVersion | null,\n-|};\n-\n \/\/ The subset of a Thenable required by things thrown by Suspense.\n \/\/ This doesn't require a value to be passed to either handler.\n export interface Wakeable {\n","body":"This API was replaced by useSyncExternalStore","commit":{"shortRevision":"8209de2695","revision":"8209de269531767b33d8db26eda41db38bfb6a27","authorName":"Andrew Clark","authoredAt":"2021-09-20T00:11:50-04:00","authorEmail":"git@andrewclark.io","subject":"Delete useMutableSource implementation (#22292)"},"parents":["f50ff357cf45d5cbda8d5a99c247e33b0477e936"],"files":[{"path":"packages\/react-debug-tools\/src\/ReactDebugHooks.js","status":"M"},{"path":"packages\/react-debug-tools\/src\/__tests__\/ReactHooksInspectionIntegration-test.js","status":"M"},{"path":"packages\/react-dom\/src\/client\/ReactDOMRoot.js","status":"M"},{"path":"packages\/react-dom\/src\/server\/ReactPartialRendererHooks.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberBeginWork.new.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberBeginWork.old.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberCompleteWork.new.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberCompleteWork.old.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberHooks.new.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberHooks.old.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberLane.new.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberLane.old.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberReconciler.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberReconciler.new.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberReconciler.old.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberRoot.new.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberRoot.old.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberUnwindWork.new.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactFiberUnwindWork.old.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactInternalTypes.js","status":"M"},{"path":"packages\/react-reconciler\/src\/ReactMutableSource.new.js","status":"D"},{"path":"packages\/react-reconciler\/src\/ReactMutableSource.old.js","status":"D"},{"path":"packages\/react-reconciler\/src\/__tests__\/useMutableSource-test.internal.js","status":"D"},{"path":"packages\/react-reconciler\/src\/__tests__\/useMutableSourceHydration-test.js","status":"D"},{"path":"packages\/react-server\/src\/ReactFizzHooks.js","status":"M"},{"path":"packages\/react-server\/src\/ReactFlightServer.js","status":"M"},{"path":"packages\/react-suspense-test-utils\/src\/ReactSuspenseTestUtils.js","status":"M"},{"path":"packages\/react\/index.classic.fb.js","status":"M"},{"path":"packages\/react\/index.experimental.js","status":"M"},{"path":"packages\/react\/index.js","status":"M"},{"path":"packages\/react\/index.modern.fb.js","status":"M"},{"path":"packages\/react\/index.stable.js","status":"M"},{"path":"packages\/react\/src\/React.js","status":"M"},{"path":"packages\/react\/src\/ReactHooks.js","status":"M"},{"path":"packages\/react\/src\/ReactMutableSource.js","status":"D"},{"path":"packages\/react\/unstable-shared-subset.experimental.js","status":"M"},{"path":"packages\/shared\/ReactTypes.js","status":"M"}]}

dillon1000/react

Files changed