diff options
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/rxjs/internal/util/subscribeToIterable.js')
-rw-r--r-- | sandbox/testAppNevena/Front/node_modules/rxjs/internal/util/subscribeToIterable.js | 33 |
1 files changed, 33 insertions, 0 deletions
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/util/subscribeToIterable.js b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/util/subscribeToIterable.js new file mode 100644 index 00000000..9d0abf33 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/util/subscribeToIterable.js @@ -0,0 +1,33 @@ +"use strict"; +Object.defineProperty(exports, "__esModule", { value: true }); +var iterator_1 = require("../symbol/iterator"); +exports.subscribeToIterable = function (iterable) { return function (subscriber) { + var iterator = iterable[iterator_1.iterator](); + do { + var item = void 0; + try { + item = iterator.next(); + } + catch (err) { + subscriber.error(err); + return subscriber; + } + if (item.done) { + subscriber.complete(); + break; + } + subscriber.next(item.value); + if (subscriber.closed) { + break; + } + } while (true); + if (typeof iterator.return === 'function') { + subscriber.add(function () { + if (iterator.return) { + iterator.return(); + } + }); + } + return subscriber; +}; }; +//# sourceMappingURL=subscribeToIterable.js.map
\ No newline at end of file |