()
| 56610 | return _makeNodeStreamIterator.apply(this, arguments); |
| 56611 | } |
| 56612 | function _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 | } |
| 56652 | function onceReadable(_x4) { |
| 56653 | return _onceReadable.apply(this, arguments); |
| 56654 | } |
nothing calls this directly
no test coverage detected