Function wrapAsyncIterator

inject.js:558–597

(stream, iterator, observer)

    }

    const wrapAsyncIterator = (stream, iterator, observer) => {
      if (!observer || !iterator || typeof iterator.next !== 'function') {
        return iterator;
      }

      return {
        async next(...nextArgs) {
          try {
            const result = await iterator.next(...nextArgs);
            if (result.done) {
              observer.closeConnection(stream);
            } else {
              observer.processChunk(result.value, stream);
            }
            return result;
          } catch (error) {
            observer.reportError(error);
            throw error;
          }
        },
        async return(...returnArgs) {
          observer.closeConnection(stream);
          if (typeof iterator.return === 'function') {
            return iterator.return(...returnArgs);
          }
          return { done: true };
        },
        async throw(...throwArgs) {
          const error = throwArgs[0] || new Error('ReadableStream iterator error');
          observer.reportError(error);
          if (typeof iterator.throw === 'function') {
            return iterator.throw(...throwArgs);
          }
          throw error;
        },
        [Symbol.asyncIterator]() {
          return this;
        }
      };
    };

    const createObservedIterator = function(originalIteratorFactory, iteratorArgs) {
      const observer = streamObserverMap.get(this);