Skip to content

Commit

Permalink
Add fallback shim for AbortController (#24285)
Browse files Browse the repository at this point in the history
* Add fallback shim for AbortController

* Replace shim with a minimal stub

* replace-fork

* Better minification

* Fix flow

* Even smaller

* replace-fork

* Revert back to object constructor

* replace-fork
  • Loading branch information
rickhanlonii authored Apr 8, 2022
1 parent b86baa1 commit 8dcedba
Show file tree
Hide file tree
Showing 4 changed files with 46 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@
// Polyfills for test environment
global.ReadableStream = require('web-streams-polyfill/ponyfill/es6').ReadableStream;
global.TextEncoder = require('util').TextEncoder;
global.AbortController = require('abort-controller');

let React;
let ReactDOMFizzServer;
Expand Down
25 changes: 23 additions & 2 deletions packages/react-reconciler/src/ReactFiberCacheComponent.new.js
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,29 @@ import {REACT_CONTEXT_TYPE} from 'shared/ReactSymbols';
import {pushProvider, popProvider} from './ReactFiberNewContext.new';
import * as Scheduler from 'scheduler';

// In environments without AbortController (e.g. tests)
// replace it with a lightweight shim that only has the features we use.
const AbortControllerLocal = enableCache
? typeof AbortController !== 'undefined'
? AbortController
: (function AbortControllerShim() {
const listeners = [];
const signal = (this.signal = {
aborted: false,
addEventListener: (type, listener) => {
listeners.push(listener);
},
});

this.abort = () => {
signal.aborted = true;
listeners.forEach(listener => listener());
};
}: AbortController)
: (null: any);

export type Cache = {|
controller: AbortController,
controller: AbortControllerLocal,
data: Map<() => mixed, mixed>,
refCount: number,
|};
Expand Down Expand Up @@ -66,7 +87,7 @@ export function createCache(): Cache {
return (null: any);
}
const cache: Cache = {
controller: new AbortController(),
controller: new AbortControllerLocal(),
data: new Map(),
refCount: 0,
};
Expand Down
25 changes: 23 additions & 2 deletions packages/react-reconciler/src/ReactFiberCacheComponent.old.js
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,29 @@ import {REACT_CONTEXT_TYPE} from 'shared/ReactSymbols';
import {pushProvider, popProvider} from './ReactFiberNewContext.old';
import * as Scheduler from 'scheduler';

// In environments without AbortController (e.g. tests)
// replace it with a lightweight shim that only has the features we use.
const AbortControllerLocal = enableCache
? typeof AbortController !== 'undefined'
? AbortController
: (function AbortControllerShim() {
const listeners = [];
const signal = (this.signal = {
aborted: false,
addEventListener: (type, listener) => {
listeners.push(listener);
},
});

this.abort = () => {
signal.aborted = true;
listeners.forEach(listener => listener());
};
}: AbortController)
: (null: any);

export type Cache = {|
controller: AbortController,
controller: AbortControllerLocal,
data: Map<() => mixed, mixed>,
refCount: number,
|};
Expand Down Expand Up @@ -66,7 +87,7 @@ export function createCache(): Cache {
return (null: any);
}
const cache: Cache = {
controller: new AbortController(),
controller: new AbortControllerLocal(),
data: new Map(),
refCount: 0,
};
Expand Down
4 changes: 0 additions & 4 deletions scripts/jest/setupEnvironment.js
Original file line number Diff line number Diff line change
@@ -1,7 +1,5 @@
/* eslint-disable */

const AbortController = require('abort-controller');

const NODE_ENV = process.env.NODE_ENV;
if (NODE_ENV !== 'development' && NODE_ENV !== 'production') {
throw new Error('NODE_ENV must either be set to development or production.');
Expand All @@ -23,8 +21,6 @@ global.__EXPERIMENTAL__ =

global.__VARIANT__ = !!process.env.VARIANT;

global.AbortController = AbortController;

if (typeof window !== 'undefined') {
global.requestIdleCallback = function(callback) {
return setTimeout(() => {
Expand Down

0 comments on commit 8dcedba

Please sign in to comment.