Function next

inject.js:564–577

(...nextArgs)

      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') {