MCPcopy Create free account
hub / github.com/microsoft/SandDance / _makeNodeStreamIterator

Function _makeNodeStreamIterator

docs/app/js/sanddance-app.js:56612–56651  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

56610 return _makeNodeStreamIterator.apply(this, arguments);
56611}
56612function _makeNodeStreamIterator() {
56613 _makeNodeStreamIterator = (0, _wrapAsyncGeneratorDefault.default)((0, _regeneratorDefault.default).mark(function _callee3(stream) {
56614 var data;
56615 return (0, _regeneratorDefault.default).wrap(function _callee3$(_context3) {
56616 while(true)switch(_context3.prev = _context3.next){
56617 case 0:
56618 _context3.next = 2;
56619 return (0, _awaitAsyncGeneratorDefault.default)(stream);
56620 case 2:
56621 stream = _context3.sent;
56622 case 3:
56623 data = stream.read();
56624 if (!(data !== null)) {
56625 _context3.next = 9;
56626 break;
56627 }
56628 _context3.next = 8;
56629 return (0, _loaderUtils.toArrayBuffer)(data);
56630 case 8:
56631 return _context3.abrupt("continue", 3);
56632 case 9:
56633 if (!stream._readableState.ended) {
56634 _context3.next = 11;
56635 break;
56636 }
56637 return _context3.abrupt("return");
56638 case 11:
56639 _context3.next = 13;
56640 return (0, _awaitAsyncGeneratorDefault.default)(onceReadable(stream));
56641 case 13:
56642 _context3.next = 3;
56643 break;
56644 case 15:
56645 case "end":
56646 return _context3.stop();
56647 }
56648 }, _callee3);
56649 }));
56650 return _makeNodeStreamIterator.apply(this, arguments);
56651}
56652function onceReadable(_x4) {
56653 return _onceReadable.apply(this, arguments);
56654}

Callers

nothing calls this directly

Calls 1

onceReadableFunction · 0.70

Tested by

no test coverage detected