Function createNativeContractScript

packages/rxjs/test/kernel/run.mjs:54–83

(bundle)

}

function createNativeContractScript(bundle) {
  return `
const done = arguments[arguments.length - 1];
const platformMap = globalThis.Observable.prototype.map;
${bundle}
const runContract = (${runExtensionKernelContract.toString()});
const expectedCases = ${JSON.stringify(extensionKernelCaseNames)};

void runContract({
  ObservableCtor: globalThis.Observable,
  platformMap,
  symbols: globalThis.__rxjsExtensionKernelPilot,
}).then(
  (completedCases) => {
    try {
      if (globalThis.Observable[Symbol.for('rxjs.observable.polyfill.info.v1')] !== undefined) {
        throw new Error('The native kernel mode selected an RxJS-marked fallback');
      }
      if (JSON.stringify(completedCases) !== JSON.stringify(expectedCases)) {
        throw new Error('The native kernel mode did not complete every case');
      }
      done({ completedCases, constructorName: globalThis.Observable.name, markedAsRxjsFallback: false });
    } catch (error) {
      done({ error: error?.stack ?? String(error) });
    }
  },
  (error) => done({ error: error?.stack ?? String(error) })
);
`;
}

async function runNativeContract() {
  const [config, browserLock, bundle] = await Promise.all([readConfig(), readBrowserLock(), buildBrowserBundle()]);