diff options
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/pairs.js')
-rw-r--r-- | sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/pairs.js | 42 |
1 files changed, 42 insertions, 0 deletions
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/pairs.js b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/pairs.js new file mode 100644 index 00000000..10037fe2 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/pairs.js @@ -0,0 +1,42 @@ +"use strict"; +Object.defineProperty(exports, "__esModule", { value: true }); +var Observable_1 = require("../Observable"); +var Subscription_1 = require("../Subscription"); +function pairs(obj, scheduler) { + if (!scheduler) { + return new Observable_1.Observable(function (subscriber) { + var keys = Object.keys(obj); + for (var i = 0; i < keys.length && !subscriber.closed; i++) { + var key = keys[i]; + if (obj.hasOwnProperty(key)) { + subscriber.next([key, obj[key]]); + } + } + subscriber.complete(); + }); + } + else { + return new Observable_1.Observable(function (subscriber) { + var keys = Object.keys(obj); + var subscription = new Subscription_1.Subscription(); + subscription.add(scheduler.schedule(dispatch, 0, { keys: keys, index: 0, subscriber: subscriber, subscription: subscription, obj: obj })); + return subscription; + }); + } +} +exports.pairs = pairs; +function dispatch(state) { + var keys = state.keys, index = state.index, subscriber = state.subscriber, subscription = state.subscription, obj = state.obj; + if (!subscriber.closed) { + if (index < keys.length) { + var key = keys[index]; + subscriber.next([key, obj[key]]); + subscription.add(this.schedule({ keys: keys, index: index + 1, subscriber: subscriber, subscription: subscription, obj: obj })); + } + else { + subscriber.complete(); + } + } +} +exports.dispatch = dispatch; +//# sourceMappingURL=pairs.js.map
\ No newline at end of file |