aboutsummaryrefslogtreecommitdiff
path: root/sandbox/testAppNevena/Front/node_modules/rxjs/internal/scheduled/scheduleIterable.js
diff options
context:
space:
mode:
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/rxjs/internal/scheduled/scheduleIterable.js')
-rw-r--r--sandbox/testAppNevena/Front/node_modules/rxjs/internal/scheduled/scheduleIterable.js48
1 files changed, 0 insertions, 48 deletions
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/scheduled/scheduleIterable.js b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/scheduled/scheduleIterable.js
deleted file mode 100644
index 3cf6bc09..00000000
--- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/scheduled/scheduleIterable.js
+++ /dev/null
@@ -1,48 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-var Observable_1 = require("../Observable");
-var Subscription_1 = require("../Subscription");
-var iterator_1 = require("../symbol/iterator");
-function scheduleIterable(input, scheduler) {
- if (!input) {
- throw new Error('Iterable cannot be null');
- }
- return new Observable_1.Observable(function (subscriber) {
- var sub = new Subscription_1.Subscription();
- var iterator;
- sub.add(function () {
- if (iterator && typeof iterator.return === 'function') {
- iterator.return();
- }
- });
- sub.add(scheduler.schedule(function () {
- iterator = input[iterator_1.iterator]();
- sub.add(scheduler.schedule(function () {
- if (subscriber.closed) {
- return;
- }
- var value;
- var done;
- try {
- var result = iterator.next();
- value = result.value;
- done = result.done;
- }
- catch (err) {
- subscriber.error(err);
- return;
- }
- if (done) {
- subscriber.complete();
- }
- else {
- subscriber.next(value);
- this.schedule();
- }
- }));
- }));
- return sub;
- });
-}
-exports.scheduleIterable = scheduleIterable;
-//# sourceMappingURL=scheduleIterable.js.map \ No newline at end of file