aboutsummaryrefslogtreecommitdiff
path: root/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/pairs.js
diff options
context:
space:
mode:
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.js42
1 files changed, 0 insertions, 42 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
deleted file mode 100644
index 10037fe2..00000000
--- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/pairs.js
+++ /dev/null
@@ -1,42 +0,0 @@
-"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