2 Object.defineProperty(exports, "__esModule", { value: true });
3 var Observable_1 = require("../Observable");
4 var Subscription_1 = require("../Subscription");
5 function pairs(obj, scheduler) {
7 return new Observable_1.Observable(function (subscriber) {
8 var keys = Object.keys(obj);
9 for (var i = 0; i < keys.length && !subscriber.closed; i++) {
11 if (obj.hasOwnProperty(key)) {
12 subscriber.next([key, obj[key]]);
15 subscriber.complete();
19 return new Observable_1.Observable(function (subscriber) {
20 var keys = Object.keys(obj);
21 var subscription = new Subscription_1.Subscription();
22 subscription.add(scheduler.schedule(dispatch, 0, { keys: keys, index: 0, subscriber: subscriber, subscription: subscription, obj: obj }));
27 exports.pairs = pairs;
28 function dispatch(state) {
29 var keys = state.keys, index = state.index, subscriber = state.subscriber, subscription = state.subscription, obj = state.obj;
30 if (!subscriber.closed) {
31 if (index < keys.length) {
32 var key = keys[index];
33 subscriber.next([key, obj[key]]);
34 subscription.add(this.schedule({ keys: keys, index: index + 1, subscriber: subscriber, subscription: subscription, obj: obj }));
37 subscriber.complete();
41 exports.dispatch = dispatch;
42 //# sourceMappingURL=pairs.js.map