You can not select more than 25 topics
			Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
		
		
		
		
		
			
		
			
				
					117 lines
				
				4.3 KiB
			
		
		
			
		
	
	
					117 lines
				
				4.3 KiB
			| 
											2 years ago
										 | "use strict"; | ||
|  | 
 | ||
|  | function _awaitAsyncGenerator(value) { return new _AwaitValue(value); } | ||
|  | 
 | ||
|  | function _wrapAsyncGenerator(fn) { return function () { return new _AsyncGenerator(fn.apply(this, arguments)); }; } | ||
|  | 
 | ||
|  | function _AsyncGenerator(gen) { var front, back; function send(key, arg) { return new Promise(function (resolve, reject) { var request = { key: key, arg: arg, resolve: resolve, reject: reject, next: null }; if (back) { back = back.next = request; } else { front = back = request; resume(key, arg); } }); } function resume(key, arg) { try { var result = gen[key](arg); var value = result.value; var wrappedAwait = value instanceof _AwaitValue; Promise.resolve(wrappedAwait ? value.wrapped : value).then(function (arg) { if (wrappedAwait) { resume(key === "return" ? "return" : "next", arg); return; } settle(result.done ? "return" : "normal", arg); }, function (err) { resume("throw", err); }); } catch (err) { settle("throw", err); } } function settle(type, value) { switch (type) { case "return": front.resolve({ value: value, done: true }); break; case "throw": front.reject(value); break; default: front.resolve({ value: value, done: false }); break; } front = front.next; if (front) { resume(front.key, front.arg); } else { back = null; } } this._invoke = send; if (typeof gen.return !== "function") { this.return = undefined; } } | ||
|  | 
 | ||
|  | if (typeof Symbol === "function" && Symbol.asyncIterator) { _AsyncGenerator.prototype[Symbol.asyncIterator] = function () { return this; }; } | ||
|  | 
 | ||
|  | _AsyncGenerator.prototype.next = function (arg) { return this._invoke("next", arg); }; | ||
|  | 
 | ||
|  | _AsyncGenerator.prototype.throw = function (arg) { return this._invoke("throw", arg); }; | ||
|  | 
 | ||
|  | _AsyncGenerator.prototype.return = function (arg) { return this._invoke("return", arg); }; | ||
|  | 
 | ||
|  | function _AwaitValue(value) { this.wrapped = value; } | ||
|  | 
 | ||
|  | module.exports = /*#__PURE__*/function () { | ||
|  |   var _iterateStream = _wrapAsyncGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee(stream) { | ||
|  |     var contents, resolveStreamEndedPromise, streamEndedPromise, ended, error, data; | ||
|  |     return regeneratorRuntime.wrap(function _callee$(_context) { | ||
|  |       while (1) { | ||
|  |         switch (_context.prev = _context.next) { | ||
|  |           case 0: | ||
|  |             contents = []; | ||
|  |             stream.on('data', function (data) { | ||
|  |               return contents.push(data); | ||
|  |             }); | ||
|  |             streamEndedPromise = new Promise(function (resolve) { | ||
|  |               return resolveStreamEndedPromise = resolve; | ||
|  |             }); | ||
|  |             ended = false; | ||
|  |             stream.on('end', function () { | ||
|  |               ended = true; | ||
|  |               resolveStreamEndedPromise(); | ||
|  |             }); | ||
|  |             error = false; | ||
|  |             stream.on('error', function (err) { | ||
|  |               error = err; | ||
|  |               resolveStreamEndedPromise(); | ||
|  |             }); | ||
|  | 
 | ||
|  |           case 7: | ||
|  |             if (!(!ended || contents.length > 0)) { | ||
|  |               _context.next = 22; | ||
|  |               break; | ||
|  |             } | ||
|  | 
 | ||
|  |             if (!(contents.length === 0)) { | ||
|  |               _context.next = 14; | ||
|  |               break; | ||
|  |             } | ||
|  | 
 | ||
|  |             stream.resume(); // eslint-disable-next-line no-await-in-loop
 | ||
|  | 
 | ||
|  |             _context.next = 12; | ||
|  |             return _awaitAsyncGenerator(Promise.race([once(stream, 'data'), streamEndedPromise])); | ||
|  | 
 | ||
|  |           case 12: | ||
|  |             _context.next = 18; | ||
|  |             break; | ||
|  | 
 | ||
|  |           case 14: | ||
|  |             stream.pause(); | ||
|  |             data = contents.shift(); | ||
|  |             _context.next = 18; | ||
|  |             return data; | ||
|  | 
 | ||
|  |           case 18: | ||
|  |             if (!error) { | ||
|  |               _context.next = 20; | ||
|  |               break; | ||
|  |             } | ||
|  | 
 | ||
|  |             throw error; | ||
|  | 
 | ||
|  |           case 20: | ||
|  |             _context.next = 7; | ||
|  |             break; | ||
|  | 
 | ||
|  |           case 22: | ||
|  |             resolveStreamEndedPromise(); | ||
|  | 
 | ||
|  |           case 23: | ||
|  |           case "end": | ||
|  |             return _context.stop(); | ||
|  |         } | ||
|  |       } | ||
|  |     }, _callee); | ||
|  |   })); | ||
|  | 
 | ||
|  |   function iterateStream(_x) { | ||
|  |     return _iterateStream.apply(this, arguments); | ||
|  |   } | ||
|  | 
 | ||
|  |   return iterateStream; | ||
|  | }(); | ||
|  | 
 | ||
|  | function once(eventEmitter, type) { | ||
|  |   // TODO: Use require('events').once when node v10 is dropped
 | ||
|  |   return new Promise(function (resolve) { | ||
|  |     var fired = false; | ||
|  | 
 | ||
|  |     var handler = function handler() { | ||
|  |       if (!fired) { | ||
|  |         fired = true; | ||
|  |         eventEmitter.removeListener(type, handler); | ||
|  |         resolve(); | ||
|  |       } | ||
|  |     }; | ||
|  | 
 | ||
|  |     eventEmitter.addListener(type, handler); | ||
|  |   }); | ||
|  | } | ||
|  | //# sourceMappingURL=iterate-stream.js.map
 |