let React;
let ReactTestRenderer;
let ReactFeatureFlags;
let Scheduler;
let Suspense;
let act;
let textCache;
let assertLog;
let waitForPaint;
let waitForAll;
let waitFor;
describe('ReactSuspense', () => {
beforeEach(() => {
jest.resetModules();
ReactFeatureFlags = require('shared/ReactFeatureFlags');
ReactFeatureFlags.replayFailedUnitOfWorkWithInvokeGuardedCallback = false;
React = require('react');
ReactTestRenderer = require('react-test-renderer');
act = require('internal-test-utils').act;
Scheduler = require('scheduler');
Suspense = React.Suspense;
const InternalTestUtils = require('internal-test-utils');
waitForAll = InternalTestUtils.waitForAll;
waitForPaint = InternalTestUtils.waitForPaint;
assertLog = InternalTestUtils.assertLog;
waitFor = InternalTestUtils.waitFor;
textCache = new Map();
});
function resolveText(text) {
const record = textCache.get(text);
if (record === undefined) {
const newRecord = {
status: 'resolved',
value: text,
};
textCache.set(text, newRecord);
} else if (record.status === 'pending') {
const thenable = record.value;
record.status = 'resolved';
record.value = text;
thenable.pings.forEach(t => t());
}
}
function readText(text) {
const record = textCache.get(text);
if (record !== undefined) {
switch (record.status) {
case 'pending':
Scheduler.log(`Suspend! [${text}]`);
throw record.value;
case 'rejected':
throw record.value;
case 'resolved':
return record.value;
}
} else {
Scheduler.log(`Suspend! [${text}]`);
const thenable = {
pings: [],
then(resolve) {
if (newRecord.status === 'pending') {
thenable.pings.push(resolve);
} else {
Promise.resolve().then(() => resolve(newRecord.value));
}
},
};
const newRecord = {
status: 'pending',
value: thenable,
};
textCache.set(text, newRecord);
throw thenable;
}
}
function Text({text}) {
Scheduler.log(text);
return text;
}
function AsyncText({text}) {
readText(text);
Scheduler.log(text);
return text;
}
it('suspends rendering and continues later', async () => {
function Bar(props) {
Scheduler.log('Bar');
return props.children;
}
function Foo({renderBar}) {
Scheduler.log('Foo');
return (
<Suspense fallback={<Text text="Loading..." />}>
{renderBar ? (
<Bar>
<AsyncText text="A" ms={100} />
<Text text="B" />
</Bar>
) : null}
</Suspense>
);
}
// Render an empty shell
const root = ReactTestRenderer.create(<Foo />, {
unstable_isConcurrent: true,
});
await waitForAll(['Foo']);
expect(root).toMatchRenderedOutput(null);
// Navigate the shell to now render the child content.
// This should suspend.
React.startTransition(() => {
root.update(<Foo renderBar={true} />);
});
await waitForAll([
'Foo',
'Bar',
// A suspends
'Suspend! [A]',
'Loading...',
]);
expect(root).toMatchRenderedOutput(null);
await waitForAll([]);
expect(root).toMatchRenderedOutput(null);
await resolveText('A');
await waitForAll(['Foo', 'Bar', 'A', 'B']);
expect(root).toMatchRenderedOutput('AB');
});
it('suspends siblings and later recovers each independently', async () => {
// Render two sibling Suspense components
const root = ReactTestRenderer.create(
<>
<Suspense fallback={<Text text="Loading A..." />}>
<AsyncText text="A" ms={5000} />
</Suspense>
<Suspense fallback={<Text text="Loading B..." />}>
<AsyncText text="B" ms={6000} />
</Suspense>
</>,
{
unstable_isConcurrent: true,
},
);
await waitForAll([
'Suspend! [A]',
'Loading A...',
'Suspend! [B]',
'Loading B...',
]);
expect(root).toMatchRenderedOutput('Loading A...Loading B...');
// Resolve first Suspense's promise and switch back to the normal view. The
// second Suspense should still show the placeholder
await act(() => resolveText('A'));
assertLog(['A']);
expect(root).toMatchRenderedOutput('ALoading B...');
// Resolve the second Suspense's promise resolves and switche back to the
// normal view
await act(() => resolveText('B'));
assertLog(['B']);
expect(root).toMatchRenderedOutput('AB');
});
it('interrupts current render if promise resolves before current render phase', async () => {
let didResolve = false;
const listeners = [];
const thenable = {
then(resolve) {
if (!didResolve) {
listeners.push(resolve);
} else {
resolve();
}
},
};
function resolveThenable() {
didResolve = true;
listeners.forEach(l => l());
}
function Async() {
if (!didResolve) {
Scheduler.log('Suspend!');
throw thenable;
}
Scheduler.log('Async');
return 'Async';
}
const root = ReactTestRenderer.create(
<>
<Suspense fallback={<Text text="Loading..." />} />
<Text text="Initial" />
</>,
{
unstable_isConcurrent: true,
},
);
await waitForAll(['Initial']);
expect(root).toMatchRenderedOutput('Initial');
// The update will suspend.
React.startTransition(() => {
root.update(
<>
<Suspense fallback={<Text text="Loading..." />}>
<Async />
</Suspense>
<Text text="After Suspense" />
<Text text="Sibling" />
</>,
);
});
// Yield past the Suspense boundary but don't complete the last sibling.
await waitFor(['Suspend!', 'Loading...', 'After Suspense']);
// The promise resolves before the current render phase has completed
resolveThenable();
assertLog([]);
expect(root).toMatchRenderedOutput('Initial');
// Start over from the root, instead of continuing.
await waitForAll([
// Async renders again *before* Sibling
'Async',
'After Suspense',
'Sibling',
]);
expect(root).toMatchRenderedOutput('AsyncAfter SuspenseSibling');
});
it('throttles fallback committing globally', async () => {
function Foo() {
Scheduler.log('Foo');
return (
<Suspense fallback={<Text text="Loading..." />}>
<AsyncText text="A" ms={200} />
<Suspense fallback={<Text text="Loading more..." />}>
<AsyncText text="B" ms={300} />
</Suspense>
</Suspense>
);
}
const root = ReactTestRenderer.create(<Foo />, {
unstable_isConcurrent: true,
});
await waitForAll(['Foo', 'Suspend! [A]', 'Loading...']);
expect(root).toMatchRenderedOutput('Loading...');
await resolveText('A');
await waitForAll(['A', 'Suspend! [B]', 'Loading more...']);
// By this point, we have enough info to show "A" and "Loading more..."
// However, we've just shown the outer fallback. So we'll delay
// showing the inner fallback hoping that B will resolve soon enough.
expect(root).toMatchRenderedOutput('Loading...');
await act(() => resolveText('B'));
// By this point, B has resolved.
// The contents of both should pop in together.
assertLog(['A', 'B']);
expect(root).toMatchRenderedOutput('AB');
});
it('does not throttle fallback committing for too long', async () => {
function Foo() {
Scheduler.log('Foo');
return (
<Suspense fallback={<Text text="Loading..." />}>
<AsyncText text="A" ms={200} />
<Suspense fallback={<Text text="Loading more..." />}>
<AsyncText text="B" ms={1200} />
</Suspense>
</Suspense>
);
}
const root = ReactTestRenderer.create(<Foo />, {
unstable_isConcurrent: true,
});
await waitForAll(['Foo', 'Suspend! [A]', 'Loading...']);
expect(root).toMatchRenderedOutput('Loading...');
await resolveText('A');
await waitForAll(['A', 'Suspend! [B]', 'Loading more...']);
// By this point, we have enough info to show "A" and "Loading more..."
// However, we've just shown the outer fallback. So we'll delay
// showing the inner fallback hoping that B will resolve soon enough.
expect(root).toMatchRenderedOutput('Loading...');
// But if we wait a bit longer, eventually we'll give up and show a
// fallback. The exact value here isn't important. It's a JND ("Just
// Noticeable Difference").
jest.advanceTimersByTime(500);
expect(root).toMatchRenderedOutput('ALoading more...');
await act(() => resolveText('B'));
assertLog(['B']);
expect(root).toMatchRenderedOutput('AB');
});
// @gate forceConcurrentByDefaultForTesting
it(
'interrupts current render when something suspends with a ' +
"delay and we've already skipped over a lower priority update in " +
'a parent',
async () => {
function interrupt() {
// React has a heuristic to batch all updates that occur within the same
// event. This is a trick to circumvent that heuristic.
ReactTestRenderer.create('whatever');
}
function App({shouldSuspend, step}) {
return (
<>
<Text text={`A${step}`} />
<Suspense fallback={<Text text="Loading..." />}>
{shouldSuspend ? <AsyncText text="Async" ms={2000} /> : null}
</Suspense>
<Text text={`B${step}`} />
<Text text={`C${step}`} />
</>
);
}
const root = ReactTestRenderer.create(null, {
unstable_isConcurrent: true,
});
root.update(<App shouldSuspend={false} step={0} />);
await waitForAll(['A0', 'B0', 'C0']);
expect(root).toMatchRenderedOutput('A0B0C0');
// This update will suspend.
root.update(<App shouldSuspend={true} step={1} />);
// Do a bit of work
await waitFor(['A1']);
// Schedule another update. This will have lower priority because it's
// a transition.
React.startTransition(() => {
root.update(<App shouldSuspend={false} step={2} />);
});
// Interrupt to trigger a restart.
interrupt();
await waitFor([
// Should have restarted the first update, because of the interruption
'A1',
'Suspend! [Async]',
'Loading...',
'B1',
]);
// Should not have committed loading state
expect(root).toMatchRenderedOutput('A0B0C0');
// After suspending, should abort the first update and switch to the
// second update. So, C1 should not appear in the log.
// TODO: This should work even if React does not yield to the main
// thread. Should use same mechanism as selective hydration to interrupt
// the render before the end of the current slice of work.
await waitForAll(['A2', 'B2', 'C2']);
expect(root).toMatchRenderedOutput('A2B2C2');
},
);
it('mounts a lazy class component in non-concurrent mode', async () => {
class Class extends React.Component {
componentDidMount() {
Scheduler.log('Did mount: ' + this.props.label);
}
componentDidUpdate() {
Scheduler.log('Did update: ' + this.props.label);
}
render() {
return <Text text={this.props.label} />;
}
}
async function fakeImport(result) {
return {default: result};
}
const LazyClass = React.lazy(() => fakeImport(Class));
const root = ReactTestRenderer.create(
<Suspense fallback={<Text text="Loading..." />}>
<LazyClass label="Hi" />
</Suspense>,
);
assertLog(['Loading...']);
expect(root).toMatchRenderedOutput('Loading...');
await LazyClass;
await waitForPaint(['Hi', 'Did mount: Hi']);
expect(root).toMatchRenderedOutput('Hi');
});
it('updates memoized child of suspense component when context updates (simple memo)', async () => {
const {useContext, createContext, useState, memo} = React;
const ValueContext = createContext(null);
const MemoizedChild = memo(function MemoizedChild() {
const text = useContext(ValueContext);
return <Text text={readText(text)} />;
});
let setValue;
function App() {
const [value, _setValue] = useState('default');
setValue = _setValue;
return (
<ValueContext.Provider value={value}>
<Suspense fallback={<Text text="Loading..." />}>
<MemoizedChild />
</Suspense>
</ValueContext.Provider>
);
}
const root = ReactTestRenderer.create(<App />, {
unstable_isConcurrent: true,
});
await waitForAll(['Suspend! [default]', 'Loading...']);
await act(() => resolveText('default'));
assertLog(['default']);
expect(root).toMatchRenderedOutput('default');
await act(() => setValue('new value'));
assertLog(['Suspend! [new value]', 'Loading...']);
await act(() => resolveText('new value'));
assertLog(['new value']);
expect(root).toMatchRenderedOutput('new value');
});
it('updates memoized child of suspense component when context updates (manual memo)', async () => {
const {useContext, createContext, useState, memo} = React;
const ValueContext = createContext(null);
const MemoizedChild = memo(
function MemoizedChild() {
const text = useContext(ValueContext);
return <Text text={readText(text)} />;
},
function areEqual(prevProps, nextProps) {
return true;
},
);
let setValue;
function App() {
const [value, _setValue] = useState('default');
setValue = _setValue;
return (
<ValueContext.Provider value={value}>
<Suspense fallback={<Text text="Loading..." />}>
<MemoizedChild />
</Suspense>
</ValueContext.Provider>
);
}
const root = ReactTestRenderer.create(<App />, {
unstable_isConcurrent: true,
});
await waitForAll(['Suspend! [default]', 'Loading...']);
await act(() => resolveText('default'));
assertLog(['default']);
expect(root).toMatchRenderedOutput('default');
await act(() => setValue('new value'));
assertLog(['Suspend! [new value]', 'Loading...']);
await act(() => resolveText('new value'));
assertLog(['new value']);
expect(root).toMatchRenderedOutput('new value');
});
it('updates memoized child of suspense component when context updates (function)', async () => {
const {useContext, createContext, useState} = React;
const ValueContext = createContext(null);
function MemoizedChild() {
const text = useContext(ValueContext);
return <Text text={readText(text)} />;
}
let setValue;
function App({children}) {
const [value, _setValue] = useState('default');
setValue = _setValue;
return (
<ValueContext.Provider value={value}>{children}</ValueContext.Provider>
);
}
const root = ReactTestRenderer.create(
<App>
<Suspense fallback={<Text text="Loading..." />}>
<MemoizedChild />
</Suspense>
</App>,
{
unstable_isConcurrent: true,
},
);
await waitForAll(['Suspend! [default]', 'Loading...']);
await act(() => resolveText('default'));
assertLog(['default']);
expect(root).toMatchRenderedOutput('default');
await act(() => setValue('new value'));
assertLog(['Suspend! [new value]', 'Loading...']);
await act(() => resolveText('new value'));
assertLog(['new value']);
expect(root).toMatchRenderedOutput('new value');
});
it('updates memoized child of suspense component when context updates (forwardRef)', async () => {
const {forwardRef, useContext, createContext, useState} = React;
const ValueContext = createContext(null);
const MemoizedChild = forwardRef(() => {
const text = useContext(ValueContext);
return <Text text={readText(text)} />;
});
let setValue;
function App({children}) {
const [value, _setValue] = useState('default');
setValue = _setValue;
return (
<ValueContext.Provider value={value}>{children}</ValueContext.Provider>
);
}
const root = ReactTestRenderer.create(
<App>
<Suspense fallback={<Text text="Loading..." />}>
<MemoizedChild />
</Suspense>
</App>,
{
unstable_isConcurrent: true,
},
);
await waitForAll(['Suspend! [default]', 'Loading...']);
await act(() => resolveText('default'));
assertLog(['default']);
expect(root).toMatchRenderedOutput('default');
await act(() => setValue('new value'));
assertLog(['Suspend! [new value]', 'Loading...']);
await act(() => resolveText('new value'));
assertLog(['new value']);
expect(root).toMatchRenderedOutput('new value');
});
it('re-fires layout effects when re-showing Suspense', async () => {
function TextWithLayout(props) {
Scheduler.log(props.text);
React.useLayoutEffect(() => {
Scheduler.log('create layout');
return () => {
Scheduler.log('destroy layout');
};
}, []);
return props.text;
}
let _setShow;
function App(props) {
const [show, setShow] = React.useState(false);
_setShow = setShow;
return (
<Suspense fallback={<Text text="Loading..." />}>
<TextWithLayout text="Child 1" />
{show && <AsyncText ms={1000} text="Child 2" />}
</Suspense>
);
}
const root = ReactTestRenderer.create(<App />, {
unstable_isConcurrent: true,
});
await waitForAll(['Child 1', 'create layout']);
expect(root).toMatchRenderedOutput('Child 1');
await act(() => {
_setShow(true);
});
assertLog([
'Child 1',
'Suspend! [Child 2]',
'Loading...',
'destroy layout',
]);
await act(() => resolveText('Child 2'));
assertLog(['Child 1', 'Child 2', 'create layout']);
expect(root).toMatchRenderedOutput(['Child 1', 'Child 2'].join(''));
});
describe('outside concurrent mode', () => {
it('a mounted class component can suspend without losing state', async () => {
class TextWithLifecycle extends React.Component {
componentDidMount() {
Scheduler.log(`Mount [${this.props.text}]`);
}
componentDidUpdate() {
Scheduler.log(`Update [${this.props.text}]`);
}
componentWillUnmount() {
Scheduler.log(`Unmount [${this.props.text}]`);
}
render() {
return <Text {...this.props} />;
}
}
let instance;
class AsyncTextWithLifecycle extends React.Component {
state = {step: 1};
componentDidMount() {
Scheduler.log(`Mount [${this.props.text}:${this.state.step}]`);
}
componentDidUpdate() {
Scheduler.log(`Update [${this.props.text}:${this.state.step}]`);
}
componentWillUnmount() {
Scheduler.log(`Unmount [${this.props.text}:${this.state.step}]`);
}
render() {
instance = this;
const text = readText(`${this.props.text}:${this.state.step}`);
return <Text text={text} />;
}
}
function App() {
return (
<Suspense fallback={<TextWithLifecycle text="Loading..." />}>
<TextWithLifecycle text="A" />
<AsyncTextWithLifecycle ms={100} text="B" ref={instance} />
<TextWithLifecycle text="C" />
</Suspense>
);
}
const root = ReactTestRenderer.create(<App />);
assertLog([
'A',
'Suspend! [B:1]',
'C',
'Loading...',
'Mount [A]',
// B's lifecycle should not fire because it suspended
// 'Mount [B]',
'Mount [C]',
'Mount [Loading...]',
]);
expect(root).toMatchRenderedOutput('Loading...');
await resolveText('B:1');
await waitForPaint([
'B:1',
'Unmount [Loading...]',
// Should be a mount, not an update
'Mount [B:1]',
]);
expect(root).toMatchRenderedOutput('AB:1C');
instance.setState({step: 2});
assertLog(['Suspend! [B:2]', 'Loading...', 'Mount [Loading...]']);
expect(root).toMatchRenderedOutput('Loading...');
await resolveText('B:2');
await waitForPaint(['B:2', 'Unmount [Loading...]', 'Update [B:2]']);
expect(root).toMatchRenderedOutput('AB:2C');
});
it('bails out on timed-out primary children even if they receive an update', async () => {
let instance;
class Stateful extends React.Component {
state = {step: 1};
render() {
instance = this;
return <Text text={`Stateful: ${this.state.step}`} />;
}
}
function App(props) {
return (
<Suspense fallback={<Text text="Loading..." />}>
<Stateful />
<AsyncText ms={1000} text={props.text} />
</Suspense>
);
}
const root = ReactTestRenderer.create(<App text="A" />);
assertLog(['Stateful: 1', 'Suspend! [A]', 'Loading...']);
await resolveText('A');
await waitForPaint(['A']);
expect(root).toMatchRenderedOutput('Stateful: 1A');
root.update(<App text="B" />);
assertLog(['Stateful: 1', 'Suspend! [B]', 'Loading...']);
expect(root).toMatchRenderedOutput('Loading...');
instance.setState({step: 2});
assertLog(['Stateful: 2', 'Suspend! [B]']);
expect(root).toMatchRenderedOutput('Loading...');
await resolveText('B');
await waitForPaint(['B']);
expect(root).toMatchRenderedOutput('Stateful: 2B');
});
it('when updating a timed-out tree, always retries the suspended component', async () => {
let instance;
class Stateful extends React.Component {
state = {step: 1};
render() {
instance = this;
return <Text text={`Stateful: ${this.state.step}`} />;
}
}
const Indirection = React.Fragment;
function App(props) {
return (
<Suspense fallback={<Text text="Loading..." />}>
<Stateful />
<Indirection>
<Indirection>
<Indirection>
<AsyncText ms={1000} text={props.text} />
</Indirection>
</Indirection>
</Indirection>
</Suspense>
);
}
const root = ReactTestRenderer.create(<App text="A" />);
assertLog(['Stateful: 1', 'Suspend! [A]', 'Loading...']);
await resolveText('A');
await waitForPaint(['A']);
expect(root).toMatchRenderedOutput('Stateful: 1A');
root.update(<App text="B" />);
assertLog(['Stateful: 1', 'Suspend! [B]', 'Loading...']);
expect(root).toMatchRenderedOutput('Loading...');
instance.setState({step: 2});
assertLog([
'Stateful: 2',
// The suspended component should suspend again. If it doesn't, the
// likely mistake is that the suspended fiber wasn't marked with
// pending work, so it was improperly treated as complete.
'Suspend! [B]',
]);
expect(root).toMatchRenderedOutput('Loading...');
await resolveText('B');
await waitForPaint(['B']);
expect(root).toMatchRenderedOutput('Stateful: 2B');
});
it('suspends in a class that has componentWillUnmount and is then deleted', () => {
class AsyncTextWithUnmount extends React.Component {
componentWillUnmount() {
Scheduler.log('will unmount');
}
render() {
return <Text text={readText(this.props.text)} />;
}
}
function App({text}) {
return (
<Suspense fallback={<Text text="Loading..." />}>
<AsyncTextWithUnmount text={text} ms={100} />
</Suspense>
);
}
const root = ReactTestRenderer.create(<App text="A" />);
assertLog(['Suspend! [A]', 'Loading...']);
root.update(<Text text="B" />);
// Should not fire componentWillUnmount
assertLog(['B']);
expect(root).toMatchRenderedOutput('B');
});
it('suspends in a component that also contains useEffect', async () => {
const {useLayoutEffect} = React;
function AsyncTextWithEffect(props) {
const text = props.text;
useLayoutEffect(() => {
Scheduler.log('Did commit: ' + text);
}, [text]);
return <Text text={readText(text)} />;
}
function App({text}) {
return (
<Suspense fallback={<Text text="Loading..." />}>
<AsyncTextWithEffect text={text} ms={100} />
</Suspense>
);
}
ReactTestRenderer.create(<App text="A" />);
assertLog(['Suspend! [A]', 'Loading...']);
await resolveText('A');
await waitForPaint(['A', 'Did commit: A']);
});
it('retries when an update is scheduled on a timed out tree', async () => {
let instance;
class Stateful extends React.Component {
state = {step: 1};
render() {
instance = this;
return <AsyncText ms={1000} text={`Step: ${this.state.step}`} />;
}
}
function App(props) {
return (
<Suspense fallback={<Text text="Loading..." />}>
<Stateful />
</Suspense>
);
}
const root = ReactTestRenderer.create(<App />, {
unstable_isConcurrent: true,
});
// Initial render
await waitForAll(['Suspend! [Step: 1]', 'Loading...']);
await act(() => resolveText('Step: 1'));
assertLog(['Step: 1']);
expect(root).toMatchRenderedOutput('Step: 1');
// Update that suspends
await act(() => {
instance.setState({step: 2});
});
assertLog(['Suspend! [Step: 2]', 'Loading...']);
expect(root).toMatchRenderedOutput('Loading...');
// Update while still suspended
instance.setState({step: 3});
await waitForAll(['Suspend! [Step: 3]']);
expect(root).toMatchRenderedOutput('Loading...');
await act(() => {
resolveText('Step: 2');
resolveText('Step: 3');
});
assertLog(['Step: 3']);
expect(root).toMatchRenderedOutput('Step: 3');
});
it('does not remount the fallback while suspended children resolve in legacy mode', async () => {
let mounts = 0;
class ShouldMountOnce extends React.Component {
componentDidMount() {
mounts++;
}
render() {
return <Text text="Loading..." />;
}
}
function App(props) {
return (
<Suspense fallback={<ShouldMountOnce />}>
<AsyncText ms={1000} text="Child 1" />
<AsyncText ms={2000} text="Child 2" />
<AsyncText ms={3000} text="Child 3" />
</Suspense>
);
}
const root = ReactTestRenderer.create(<App />);
// Initial render
assertLog([
'Suspend! [Child 1]',
'Suspend! [Child 2]',
'Suspend! [Child 3]',
'Loading...',
]);
await waitForAll([]);
await resolveText('Child 1');
await waitForPaint([
'Child 1',
'Suspend! [Child 2]',
'Suspend! [Child 3]',
]);
await resolveText('Child 2');
await waitForPaint(['Child 2', 'Suspend! [Child 3]']);
await resolveText('Child 3');
await waitForPaint(['Child 3']);
expect(root).toMatchRenderedOutput(
['Child 1', 'Child 2', 'Child 3'].join(''),
);
expect(mounts).toBe(1);
});
it('does not get stuck with fallback in concurrent mode for a large delay', async () => {
function App(props) {
return (
<Suspense fallback={<Text text="Loading..." />}>
<AsyncText text="Child 1" />
<AsyncText text="Child 2" />
</Suspense>
);
}
const root = ReactTestRenderer.create(<App />, {
unstable_isConcurrent: true,
});
await waitForAll(['Suspend! [Child 1]', 'Loading...']);
await resolveText('Child 1');
await waitForAll(['Child 1', 'Suspend! [Child 2]']);
jest.advanceTimersByTime(6000);
await act(() => resolveText('Child 2'));
assertLog(['Child 1', 'Child 2']);
expect(root).toMatchRenderedOutput(['Child 1', 'Child 2'].join(''));
});
it('reuses effects, including deletions, from the suspended tree', async () => {
const {useState} = React;
let setTab;
function App() {
const [tab, _setTab] = useState(0);
setTab = _setTab;
return (
<Suspense fallback={<Text text="Loading..." />}>
<AsyncText key={tab} text={'Tab: ' + tab} ms={1000} />
<Text key={tab + 'sibling'} text=" + sibling" />
</Suspense>
);
}
const root = ReactTestRenderer.create(<App />);
assertLog(['Suspend! [Tab: 0]', ' + sibling', 'Loading...']);
expect(root).toMatchRenderedOutput('Loading...');
await resolveText('Tab: 0');
await waitForPaint(['Tab: 0']);
expect(root).toMatchRenderedOutput('Tab: 0 + sibling');
await act(() => setTab(1));
assertLog(['Suspend! [Tab: 1]', ' + sibling', 'Loading...']);
expect(root).toMatchRenderedOutput('Loading...');
await resolveText('Tab: 1');
await waitForPaint(['Tab: 1']);
expect(root).toMatchRenderedOutput('Tab: 1 + sibling');
await act(() => setTab(2));
assertLog(['Suspend! [Tab: 2]', ' + sibling', 'Loading...']);
expect(root).toMatchRenderedOutput('Loading...');
await resolveText('Tab: 2');
await waitForPaint(['Tab: 2']);
expect(root).toMatchRenderedOutput('Tab: 2 + sibling');
});
it('does not warn if a mounted component is pinged', async () => {
const {useState} = React;
const root = ReactTestRenderer.create(null);
let setStep;
function UpdatingText({text, ms}) {
const [step, _setStep] = useState(0);
setStep = _setStep;
const fullText = `${text}:${step}`;
return <Text text={readText(fullText)} />;
}
root.update(
<Suspense fallback={<Text text="Loading..." />}>
<UpdatingText text="A" ms={1000} />
</Suspense>,
);
assertLog(['Suspend! [A:0]', 'Loading...']);
await resolveText('A:0');
await waitForPaint(['A:0']);
expect(root).toMatchRenderedOutput('A:0');
await act(() => setStep(1));
assertLog(['Suspend! [A:1]', 'Loading...']);
expect(root).toMatchRenderedOutput('Loading...');
await act(() => {
root.update(null);
});
});
it('memoizes promise listeners per thread ID to prevent redundant renders', async () => {
function App() {
return (
<Suspense fallback={<Text text="Loading..." />}>
<AsyncText text="A" ms={1000} />
<AsyncText text="B" ms={2000} />
<AsyncText text="C" ms={3000} />
</Suspense>
);
}
const root = ReactTestRenderer.create(null);
root.update(<App />);
assertLog(['Suspend! [A]', 'Suspend! [B]', 'Suspend! [C]', 'Loading...']);
await resolveText('A');
await waitForPaint([
'A',
// The promises for B and C have now been thrown twice
'Suspend! [B]',
'Suspend! [C]',
]);
await resolveText('B');
await waitForPaint([
// Even though the promise for B was thrown twice, we should only
// re-render once.
'B',
// The promise for C has now been thrown three times
'Suspend! [C]',
]);
await resolveText('C');
await waitForPaint([
// Even though the promise for C was thrown three times, we should only
// re-render once.
'C',
]);
});
it('#14162', async () => {
const {lazy} = React;
function Hello() {
return <span>hello</span>;
}
async function fetchComponent() {
return new Promise(r => {
// simulating a delayed import() call
setTimeout(r, 1000, {default: Hello});
});
}
const LazyHello = lazy(fetchComponent);
class App extends React.Component {
state = {render: false};
componentDidMount() {
setTimeout(() => this.setState({render: true}));
}
render() {
return (
<Suspense fallback={<span>loading...</span>}>
{this.state.render && <LazyHello />}
</Suspense>
);
}
}
const root = ReactTestRenderer.create(null);
await act(() => {
root.update(<App name="world" />);
});
});
it('updates memoized child of suspense component when context updates (simple memo)', async () => {
const {useContext, createContext, useState, memo} = React;
const ValueContext = createContext(null);
const MemoizedChild = memo(function MemoizedChild() {
const text = useContext(ValueContext);
return <Text text={readText(text)} />;
});
let setValue;
function App() {
const [value, _setValue] = useState('default');
setValue = _setValue;
return (
<ValueContext.Provider value={value}>
<Suspense fallback={<Text text="Loading..." />}>
<MemoizedChild />
</Suspense>
</ValueContext.Provider>
);
}
const root = ReactTestRenderer.create(<App />);
assertLog(['Suspend! [default]', 'Loading...']);
await resolveText('default');
await waitForPaint(['default']);
expect(root).toMatchRenderedOutput('default');
await act(() => setValue('new value'));
assertLog(['Suspend! [new value]', 'Loading...']);
await resolveText('new value');
await waitForPaint(['new value']);
expect(root).toMatchRenderedOutput('new value');
});
it('updates memoized child of suspense component when context updates (manual memo)', async () => {
const {useContext, createContext, useState, memo} = React;
const ValueContext = createContext(null);
const MemoizedChild = memo(
function MemoizedChild() {
const text = useContext(ValueContext);
return <Text text={readText(text)} />;
},
function areEqual(prevProps, nextProps) {
return true;
},
);
let setValue;
function App() {
const [value, _setValue] = useState('default');
setValue = _setValue;
return (
<ValueContext.Provider value={value}>
<Suspense fallback={<Text text="Loading..." />}>
<MemoizedChild />
</Suspense>
</ValueContext.Provider>
);
}
const root = ReactTestRenderer.create(<App />);
assertLog(['Suspend! [default]', 'Loading...']);
await resolveText('default');
await waitForPaint(['default']);
expect(root).toMatchRenderedOutput('default');
await act(() => setValue('new value'));
assertLog(['Suspend! [new value]', 'Loading...']);
await resolveText('new value');
await waitForPaint(['new value']);
expect(root).toMatchRenderedOutput('new value');
});
it('updates memoized child of suspense component when context updates (function)', async () => {
const {useContext, createContext, useState} = React;
const ValueContext = createContext(null);
function MemoizedChild() {
const text = useContext(ValueContext);
return <Text text={readText(text)} />;
}
let setValue;
function App({children}) {
const [value, _setValue] = useState('default');
setValue = _setValue;
return (
<ValueContext.Provider value={value}>
{children}
</ValueContext.Provider>
);
}
const root = ReactTestRenderer.create(
<App>
<Suspense fallback={<Text text="Loading..." />}>
<MemoizedChild />
</Suspense>
</App>,
);
assertLog(['Suspend! [default]', 'Loading...']);
await resolveText('default');
await waitForPaint(['default']);
expect(root).toMatchRenderedOutput('default');
await act(() => setValue('new value'));
assertLog(['Suspend! [new value]', 'Loading...']);
await resolveText('new value');
await waitForPaint(['new value']);
expect(root).toMatchRenderedOutput('new value');
});
it('updates memoized child of suspense component when context updates (forwardRef)', async () => {
const {forwardRef, useContext, createContext, useState} = React;
const ValueContext = createContext(null);
const MemoizedChild = forwardRef(function MemoizedChild() {
const text = useContext(ValueContext);
return <Text text={readText(text)} />;
});
let setValue;
function App() {
const [value, _setValue] = useState('default');
setValue = _setValue;
return (
<ValueContext.Provider value={value}>
<Suspense fallback={<Text text="Loading..." />}>
<MemoizedChild />
</Suspense>
</ValueContext.Provider>
);
}
const root = ReactTestRenderer.create(<App />);
assertLog(['Suspend! [default]', 'Loading...']);
await resolveText('default');
await waitForPaint(['default']);
expect(root).toMatchRenderedOutput('default');
await act(() => setValue('new value'));
assertLog(['Suspend! [new value]', 'Loading...']);
await resolveText('new value');
await waitForPaint(['new value']);
expect(root).toMatchRenderedOutput('new value');
});
it('updates context consumer within child of suspended suspense component when context updates', async () => {
const {createContext, useState} = React;
const ValueContext = createContext(null);
const promiseThatNeverResolves = new Promise(() => {});
function Child() {
return (
<ValueContext.Consumer>
{value => {
Scheduler.log(`Received context value [${value}]`);
if (value === 'default') return <Text text="default" />;
throw promiseThatNeverResolves;
}}
</ValueContext.Consumer>
);
}
let setValue;
function Wrapper({children}) {
const [value, _setValue] = useState('default');
setValue = _setValue;
return (
<ValueContext.Provider value={value}>
{children}
</ValueContext.Provider>
);
}
function App() {
return (
<Wrapper>
<Suspense fallback={<Text text="Loading..." />}>
<Child />
</Suspense>
</Wrapper>
);
}
const root = ReactTestRenderer.create(<App />);
assertLog(['Received context value [default]', 'default']);
expect(root).toMatchRenderedOutput('default');
await act(() => setValue('new value'));
assertLog(['Received context value [new value]', 'Loading...']);
expect(root).toMatchRenderedOutput('Loading...');
await act(() => setValue('default'));
assertLog(['Received context value [default]', 'default']);
expect(root).toMatchRenderedOutput('default');
});
});
});