Schedule work to update Context.Consumer inside Suspense

Author: okmttdhr

packages/react-reconciler/src/ReactFiberNewContext.new.js

@@ -20,9 +20,12 @@ import type {SharedQueue} from './ReactUpdateQueue.new';
 import {isPrimaryRenderer} from './ReactFiberHostConfig';
 import {createCursor, push, pop} from './ReactFiberStack.new';
 import {
+  ContextConsumer,
   ContextProvider,
   ClassComponent,
   DehydratedFragment,
+  OffscreenComponent,
+  SuspenseComponent,
 } from './ReactWorkTags';
 import {
   NoLanes,
@@ -157,6 +160,10 @@ export function scheduleWorkOnParentPath(
       !isSubsetOfLanes(alternate.childLanes, renderLanes)
     ) {
       alternate.childLanes = mergeLanes(alternate.childLanes, renderLanes);
+    } else {
+      // Neither alternate was updated, which means the rest of the
+      // ancestor path already has sufficient priority.
+      break;
     }
     node = node.return;
   }
@@ -361,6 +368,66 @@ function propagateContextChanges<T>(
             }
             scheduleWorkOnParentPath(consumer.return, renderLanes);
 
+            // If Context.Consumer is a descendant of Suspense,
+            // `scheduleWorkOnParentPath` may break before it get to Suspense.
+            // Schedule work to avoid bailout before Context.Consumer receives the value.
+            const contextConsumerIsDescendantOfSuspense =
+              workInProgress.tag === SuspenseComponent &&
+              workInProgress.child.tag === OffscreenComponent &&
+              consumer.tag === ContextConsumer;
+            if (contextConsumerIsDescendantOfSuspense) {
+              console.log('  contextConsumerWrappedBySuspense');
+              if (!isSubsetOfLanes(workInProgress.childLanes, renderLanes)) {
+                workInProgress.childLanes = mergeLanes(
+                  workInProgress.childLanes,
+                  renderLanes,
+                );
+                if (workInProgress.alternate !== null) {
+                  workInProgress.alternate.childLanes = mergeLanes(
+                    workInProgress.alternate.childLanes,
+                    renderLanes,
+                  );
+                }
+              } else if (
+                workInProgress.alternate !== null &&
+                !isSubsetOfLanes(
+                  workInProgress.alternate.childLanes,
+                  renderLanes,
+                )
+              ) {
+                workInProgress.alternate.childLanes = mergeLanes(
+                  workInProgress.alternate.childLanes,
+                  renderLanes,
+                );
+              }
+              const primaryChildFragment = workInProgress.child;
+              if (
+                !isSubsetOfLanes(primaryChildFragment.childLanes, renderLanes)
+              ) {
+                primaryChildFragment.childLanes = mergeLanes(
+                  primaryChildFragment.childLanes,
+                  renderLanes,
+                );
+                if (primaryChildFragment.alternate !== null) {
+                  primaryChildFragment.alternate.childLanes = mergeLanes(
+                    primaryChildFragment.alternate.childLanes,
+                    renderLanes,
+                  );
+                }
+              } else if (
+                primaryChildFragment.alternate !== null &&
+                !isSubsetOfLanes(
+                  primaryChildFragment.alternate.childLanes,
+                  renderLanes,
+                )
+              ) {
+                primaryChildFragment.alternate.childLanes = mergeLanes(
+                  primaryChildFragment.alternate.childLanes,
+                  renderLanes,
+                );
+              }
+            }
+
             if (!forcePropagateEntireTree) {
               // During lazy propagation, when we find a match, we can defer
               // propagating changes to the children, because we're going to

packages/react-reconciler/src/ReactFiberNewContext.old.js

@@ -157,6 +157,10 @@ export function scheduleWorkOnParentPath(
       !isSubsetOfLanes(alternate.childLanes, renderLanes)
     ) {
       alternate.childLanes = mergeLanes(alternate.childLanes, renderLanes);
+    } else {
+      // Neither alternate was updated, which means the rest of the
+      // ancestor path already has sufficient priority.
+      break;
     }
     node = node.return;
   }