Function ZoneQueueRunner

packages/zone.js/lib/jasmine/jasmine.ts:252–311

(this: QueueRunner, attrs: QueueRunnerAttrs)

    privateApis.QueueRunner = (function (_super) {
      __extends(ZoneQueueRunner, _super);
      function ZoneQueueRunner(this: QueueRunner, attrs: QueueRunnerAttrs) {
        if (attrs.onComplete) {
          attrs.onComplete = ((fn) => () => {
            // All functions are done, clear the test zone.
            this.testProxyZone = null;
            this.testProxyZoneSpec = null;
            ambientZone.scheduleMicroTask('jasmine.onComplete', fn);
          })(attrs.onComplete);
        }

        const nativeSetTimeout = global[Zone.__symbol__('setTimeout')];
        const nativeClearTimeout = global[Zone.__symbol__('clearTimeout')];
        if (nativeSetTimeout) {
          // should run setTimeout inside jasmine outside of zone
          attrs.timeout = {
            setTimeout: nativeSetTimeout ? nativeSetTimeout : global.setTimeout,
            clearTimeout: nativeClearTimeout ? nativeClearTimeout : global.clearTimeout,
          };
        }

        // create a userContext to hold the queueRunner itself
        // so we can access the testProxy in it/xit/beforeEach ...
        if (privateApis.UserContext) {
          if (!attrs.userContext) {
            attrs.userContext = new privateApis.UserContext();
          }
          attrs.userContext.queueRunner = this;
        } else {
          if (!attrs.userContext) {
            attrs.userContext = {};
          }
          attrs.userContext.queueRunner = this;
        }

        // patch attrs.onException
        const onException = attrs.onException;
        attrs.onException = function (this: undefined | QueueRunner, error: any) {
          if (
            error &&
            error.message ===
              'Timeout - Async callback was not invoked within timeout specified by jasmine.DEFAULT_TIMEOUT_INTERVAL.'
          ) {
            // jasmine timeout, we can make the error message more
            // reasonable to tell what tasks are pending
            const proxyZoneSpec: any = this && this.testProxyZoneSpec;
            if (proxyZoneSpec) {
              const pendingTasksInfo = proxyZoneSpec.getAndClearPendingTasksInfo();
              try {
                // try catch here in case error.message is not writable
                error.message += pendingTasksInfo;
              } catch (err) {}
            }
          }
          if (onException) {
            onException.call(this, error);
          }
        };