Function createObservedIterator

inject.js:599–612

(originalIteratorFactory, iteratorArgs)

    };

    const createObservedIterator = function(originalIteratorFactory, iteratorArgs) {
      const observer = streamObserverMap.get(this);
      if (!observer) {
        return originalIteratorFactory.apply(this, iteratorArgs);
      }

      streamsCreatingAsyncIterator.add(this);
      try {
        const iterator = originalIteratorFactory.apply(this, iteratorArgs);
        return wrapAsyncIterator(this, iterator, observer);
      } finally {
        streamsCreatingAsyncIterator.delete(this);
      }
    };

    if (typeof originalValues === 'function') {
      proto.values = function(...valuesArgs) {