esnext.async-iterator.from.js 1.7 KB

1234567891011121314151617181920212223242526272829303132333435363738
  1. // https://github.com/tc39/proposal-iterator-helpers
  2. var $ = require('../internals/export');
  3. var apply = require('../internals/function-apply');
  4. var anObject = require('../internals/an-object');
  5. var toObject = require('../internals/to-object');
  6. var isPrototypeOf = require('../internals/object-is-prototype-of');
  7. var AsyncIteratorPrototype = require('../internals/async-iterator-prototype');
  8. var createAsyncIteratorProxy = require('../internals/async-iterator-create-proxy');
  9. var getAsyncIterator = require('../internals/get-async-iterator');
  10. var getIterator = require('../internals/get-iterator');
  11. var getIteratorDirect = require('../internals/get-iterator-direct');
  12. var getIteratorMethod = require('../internals/get-iterator-method');
  13. var getMethod = require('../internals/get-method');
  14. var wellKnownSymbol = require('../internals/well-known-symbol');
  15. var AsyncFromSyncIterator = require('../internals/async-from-sync-iterator');
  16. var ASYNC_ITERATOR = wellKnownSymbol('asyncIterator');
  17. var AsyncIteratorProxy = createAsyncIteratorProxy(function (Promise, args) {
  18. return anObject(apply(this.next, this.iterator, args));
  19. }, true);
  20. $({ target: 'AsyncIterator', stat: true, forced: true }, {
  21. from: function from(O) {
  22. var object = toObject(O);
  23. var usingIterator = getMethod(object, ASYNC_ITERATOR);
  24. var iterator;
  25. if (usingIterator) {
  26. iterator = getAsyncIterator(object, usingIterator);
  27. if (isPrototypeOf(AsyncIteratorPrototype, iterator)) return iterator;
  28. }
  29. if (iterator === undefined) {
  30. usingIterator = getIteratorMethod(object);
  31. if (usingIterator) return new AsyncFromSyncIterator(getIterator(object, usingIterator));
  32. }
  33. return new AsyncIteratorProxy(getIteratorDirect(iterator !== undefined ? iterator : object));
  34. }
  35. });