asyncIterator.js 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. var _Symbol = require("@babel/runtime-corejs3/core-js/symbol");
  2. var _Symbol$asyncIterator = require("@babel/runtime-corejs3/core-js/symbol/async-iterator");
  3. var _Symbol$iterator = require("@babel/runtime-corejs3/core-js/symbol/iterator");
  4. var _Promise = require("@babel/runtime-corejs3/core-js/promise");
  5. function _asyncIterator(iterable) {
  6. var method,
  7. async,
  8. sync,
  9. retry = 2;
  10. for ("undefined" != typeof _Symbol && (async = _Symbol$asyncIterator, sync = _Symbol$iterator); retry--;) {
  11. if (async && null != (method = iterable[async])) return method.call(iterable);
  12. if (sync && null != (method = iterable[sync])) return new AsyncFromSyncIterator(method.call(iterable));
  13. async = "@@asyncIterator", sync = "@@iterator";
  14. }
  15. throw new TypeError("Object is not async iterable");
  16. }
  17. function AsyncFromSyncIterator(s) {
  18. function AsyncFromSyncIteratorContinuation(r) {
  19. if (Object(r) !== r) return _Promise.reject(new TypeError(r + " is not an object."));
  20. var done = r.done;
  21. return _Promise.resolve(r.value).then(function (value) {
  22. return {
  23. value: value,
  24. done: done
  25. };
  26. });
  27. }
  28. return AsyncFromSyncIterator = function AsyncFromSyncIterator(s) {
  29. this.s = s, this.n = s.next;
  30. }, AsyncFromSyncIterator.prototype = {
  31. s: null,
  32. n: null,
  33. next: function next() {
  34. return AsyncFromSyncIteratorContinuation(this.n.apply(this.s, arguments));
  35. },
  36. "return": function _return(value) {
  37. var ret = this.s["return"];
  38. return void 0 === ret ? _Promise.resolve({
  39. value: value,
  40. done: !0
  41. }) : AsyncFromSyncIteratorContinuation(ret.apply(this.s, arguments));
  42. },
  43. "throw": function _throw(value) {
  44. var thr = this.s["return"];
  45. return void 0 === thr ? _Promise.reject(value) : AsyncFromSyncIteratorContinuation(thr.apply(this.s, arguments));
  46. }
  47. }, new AsyncFromSyncIterator(s);
  48. }
  49. module.exports = _asyncIterator, module.exports.__esModule = true, module.exports["default"] = module.exports;