aboutsummaryrefslogtreecommitdiff
path: root/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled
diff options
context:
space:
mode:
authorDanijel Andjelkovic <adanijel99@gmail.com>2022-03-01 21:54:41 +0100
committerDanijel Andjelkovic <adanijel99@gmail.com>2022-03-01 21:54:41 +0100
commit6c8128f9fd5a5d0be115806c35a21b3d683df8d6 (patch)
treef46c2f6b3b9b294ff32bd75c08ccdc9e7a8cc4ef /sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled
parent2400b84e95913665da6279114168148444b8f9ab (diff)
parent7d3640f824f46490b47bd95f1c5a16644f712068 (diff)
Merge branch 'dev' of http://gitlab.pmf.kg.ac.rs/igrannonica/neuronstellar into logo
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled')
-rw-r--r--sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleArray.js21
-rw-r--r--sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleArray.js.map1
-rw-r--r--sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleIterable.js46
-rw-r--r--sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleIterable.js.map1
-rw-r--r--sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleObservable.js19
-rw-r--r--sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleObservable.js.map1
-rw-r--r--sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/schedulePromise.js20
-rw-r--r--sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/schedulePromise.js.map1
-rw-r--r--sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduled.js27
-rw-r--r--sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduled.js.map1
10 files changed, 138 insertions, 0 deletions
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleArray.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleArray.js
new file mode 100644
index 00000000..b9807565
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleArray.js
@@ -0,0 +1,21 @@
+/** PURE_IMPORTS_START _Observable,_Subscription PURE_IMPORTS_END */
+import { Observable } from '../Observable';
+import { Subscription } from '../Subscription';
+export function scheduleArray(input, scheduler) {
+ return new Observable(function (subscriber) {
+ var sub = new Subscription();
+ var i = 0;
+ sub.add(scheduler.schedule(function () {
+ if (i === input.length) {
+ subscriber.complete();
+ return;
+ }
+ subscriber.next(input[i++]);
+ if (!subscriber.closed) {
+ sub.add(this.schedule());
+ }
+ }));
+ return sub;
+ });
+}
+//# sourceMappingURL=scheduleArray.js.map
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleArray.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleArray.js.map
new file mode 100644
index 00000000..2a01c6cc
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleArray.js.map
@@ -0,0 +1 @@
+{"version":3,"file":"scheduleArray.js","sources":["../../../src/internal/scheduled/scheduleArray.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,UAAU,EAAE,MAAM,eAAe,CAAC;AAE3C,OAAO,EAAE,YAAY,EAAE,MAAM,iBAAiB,CAAC;AAE/C,MAAM,UAAU,aAAa,CAAI,KAAmB,EAAE,SAAwB;IAC5E,OAAO,IAAI,UAAU,CAAI,UAAA,UAAU;QACjC,IAAM,GAAG,GAAG,IAAI,YAAY,EAAE,CAAC;QAC/B,IAAI,CAAC,GAAG,CAAC,CAAC;QACV,GAAG,CAAC,GAAG,CAAC,SAAS,CAAC,QAAQ,CAAC;YACzB,IAAI,CAAC,KAAK,KAAK,CAAC,MAAM,EAAE;gBACtB,UAAU,CAAC,QAAQ,EAAE,CAAC;gBACtB,OAAO;aACR;YACD,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;YAC5B,IAAI,CAAC,UAAU,CAAC,MAAM,EAAE;gBACtB,GAAG,CAAC,GAAG,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC,CAAC;aAC1B;QACH,CAAC,CAAC,CAAC,CAAC;QACJ,OAAO,GAAG,CAAC;IACb,CAAC,CAAC,CAAC;AACL,CAAC"}
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleIterable.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleIterable.js
new file mode 100644
index 00000000..c199cc9a
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleIterable.js
@@ -0,0 +1,46 @@
+/** PURE_IMPORTS_START _Observable,_Subscription,_symbol_iterator PURE_IMPORTS_END */
+import { Observable } from '../Observable';
+import { Subscription } from '../Subscription';
+import { iterator as Symbol_iterator } from '../symbol/iterator';
+export function scheduleIterable(input, scheduler) {
+ if (!input) {
+ throw new Error('Iterable cannot be null');
+ }
+ return new Observable(function (subscriber) {
+ var sub = new Subscription();
+ var iterator;
+ sub.add(function () {
+ if (iterator && typeof iterator.return === 'function') {
+ iterator.return();
+ }
+ });
+ sub.add(scheduler.schedule(function () {
+ iterator = input[Symbol_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;
+ });
+}
+//# sourceMappingURL=scheduleIterable.js.map
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleIterable.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleIterable.js.map
new file mode 100644
index 00000000..1c1d88b8
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleIterable.js.map
@@ -0,0 +1 @@
+{"version":3,"file":"scheduleIterable.js","sources":["../../../src/internal/scheduled/scheduleIterable.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,UAAU,EAAE,MAAM,eAAe,CAAC;AAE3C,OAAO,EAAE,YAAY,EAAE,MAAM,iBAAiB,CAAC;AAC/C,OAAO,EAAE,QAAQ,IAAI,eAAe,EAAE,MAAM,oBAAoB,CAAC;AAEjE,MAAM,UAAU,gBAAgB,CAAI,KAAkB,EAAE,SAAwB;IAC9E,IAAI,CAAC,KAAK,EAAE;QACV,MAAM,IAAI,KAAK,CAAC,yBAAyB,CAAC,CAAC;KAC5C;IACD,OAAO,IAAI,UAAU,CAAI,UAAA,UAAU;QACjC,IAAM,GAAG,GAAG,IAAI,YAAY,EAAE,CAAC;QAC/B,IAAI,QAAqB,CAAC;QAC1B,GAAG,CAAC,GAAG,CAAC;YAEN,IAAI,QAAQ,IAAI,OAAO,QAAQ,CAAC,MAAM,KAAK,UAAU,EAAE;gBACrD,QAAQ,CAAC,MAAM,EAAE,CAAC;aACnB;QACH,CAAC,CAAC,CAAC;QACH,GAAG,CAAC,GAAG,CAAC,SAAS,CAAC,QAAQ,CAAC;YACzB,QAAQ,GAAG,KAAK,CAAC,eAAe,CAAC,EAAE,CAAC;YACpC,GAAG,CAAC,GAAG,CAAC,SAAS,CAAC,QAAQ,CAAC;gBACzB,IAAI,UAAU,CAAC,MAAM,EAAE;oBACrB,OAAO;iBACR;gBACD,IAAI,KAAQ,CAAC;gBACb,IAAI,IAAa,CAAC;gBAClB,IAAI;oBACF,IAAM,MAAM,GAAG,QAAQ,CAAC,IAAI,EAAE,CAAC;oBAC/B,KAAK,GAAG,MAAM,CAAC,KAAK,CAAC;oBACrB,IAAI,GAAG,MAAM,CAAC,IAAI,CAAC;iBACpB;gBAAC,OAAO,GAAG,EAAE;oBACZ,UAAU,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;oBACtB,OAAO;iBACR;gBACD,IAAI,IAAI,EAAE;oBACR,UAAU,CAAC,QAAQ,EAAE,CAAC;iBACvB;qBAAM;oBACL,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;oBACvB,IAAI,CAAC,QAAQ,EAAE,CAAC;iBACjB;YACH,CAAC,CAAC,CAAC,CAAC;QACN,CAAC,CAAC,CAAC,CAAC;QACJ,OAAO,GAAG,CAAC;IACb,CAAC,CAAC,CAAC;AACL,CAAC"}
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleObservable.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleObservable.js
new file mode 100644
index 00000000..226f596a
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleObservable.js
@@ -0,0 +1,19 @@
+/** PURE_IMPORTS_START _Observable,_Subscription,_symbol_observable PURE_IMPORTS_END */
+import { Observable } from '../Observable';
+import { Subscription } from '../Subscription';
+import { observable as Symbol_observable } from '../symbol/observable';
+export function scheduleObservable(input, scheduler) {
+ return new Observable(function (subscriber) {
+ var sub = new Subscription();
+ sub.add(scheduler.schedule(function () {
+ var observable = input[Symbol_observable]();
+ sub.add(observable.subscribe({
+ next: function (value) { sub.add(scheduler.schedule(function () { return subscriber.next(value); })); },
+ error: function (err) { sub.add(scheduler.schedule(function () { return subscriber.error(err); })); },
+ complete: function () { sub.add(scheduler.schedule(function () { return subscriber.complete(); })); },
+ }));
+ }));
+ return sub;
+ });
+}
+//# sourceMappingURL=scheduleObservable.js.map
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleObservable.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleObservable.js.map
new file mode 100644
index 00000000..0fd99fbe
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduleObservable.js.map
@@ -0,0 +1 @@
+{"version":3,"file":"scheduleObservable.js","sources":["../../../src/internal/scheduled/scheduleObservable.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,UAAU,EAAE,MAAM,eAAe,CAAC;AAC3C,OAAO,EAAE,YAAY,EAAE,MAAM,iBAAiB,CAAC;AAC/C,OAAO,EAAE,UAAU,IAAI,iBAAiB,EAAE,MAAM,sBAAsB,CAAC;AAGvE,MAAM,UAAU,kBAAkB,CAAI,KAA2B,EAAE,SAAwB;IACzF,OAAO,IAAI,UAAU,CAAI,UAAA,UAAU;QACjC,IAAM,GAAG,GAAG,IAAI,YAAY,EAAE,CAAC;QAC/B,GAAG,CAAC,GAAG,CAAC,SAAS,CAAC,QAAQ,CAAC;YACzB,IAAM,UAAU,GAAoB,KAAK,CAAC,iBAAiB,CAAC,EAAE,CAAC;YAC/D,GAAG,CAAC,GAAG,CAAC,UAAU,CAAC,SAAS,CAAC;gBAC3B,IAAI,YAAC,KAAK,IAAI,GAAG,CAAC,GAAG,CAAC,SAAS,CAAC,QAAQ,CAAC,cAAM,OAAA,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,EAAtB,CAAsB,CAAC,CAAC,CAAC,CAAC,CAAC;gBAC1E,KAAK,YAAC,GAAG,IAAI,GAAG,CAAC,GAAG,CAAC,SAAS,CAAC,QAAQ,CAAC,cAAM,OAAA,UAAU,CAAC,KAAK,CAAC,GAAG,CAAC,EAArB,CAAqB,CAAC,CAAC,CAAC,CAAC,CAAC;gBACxE,QAAQ,gBAAK,GAAG,CAAC,GAAG,CAAC,SAAS,CAAC,QAAQ,CAAC,cAAM,OAAA,UAAU,CAAC,QAAQ,EAAE,EAArB,CAAqB,CAAC,CAAC,CAAC,CAAC,CAAC;aACzE,CAAC,CAAC,CAAC;QACN,CAAC,CAAC,CAAC,CAAC;QACJ,OAAO,GAAG,CAAC;IACb,CAAC,CAAC,CAAC;AACL,CAAC"}
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/schedulePromise.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/schedulePromise.js
new file mode 100644
index 00000000..e2f79e3d
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/schedulePromise.js
@@ -0,0 +1,20 @@
+/** PURE_IMPORTS_START _Observable,_Subscription PURE_IMPORTS_END */
+import { Observable } from '../Observable';
+import { Subscription } from '../Subscription';
+export function schedulePromise(input, scheduler) {
+ return new Observable(function (subscriber) {
+ var sub = new Subscription();
+ sub.add(scheduler.schedule(function () {
+ return input.then(function (value) {
+ sub.add(scheduler.schedule(function () {
+ subscriber.next(value);
+ sub.add(scheduler.schedule(function () { return subscriber.complete(); }));
+ }));
+ }, function (err) {
+ sub.add(scheduler.schedule(function () { return subscriber.error(err); }));
+ });
+ }));
+ return sub;
+ });
+}
+//# sourceMappingURL=schedulePromise.js.map
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/schedulePromise.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/schedulePromise.js.map
new file mode 100644
index 00000000..98fc42fe
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/schedulePromise.js.map
@@ -0,0 +1 @@
+{"version":3,"file":"schedulePromise.js","sources":["../../../src/internal/scheduled/schedulePromise.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,UAAU,EAAE,MAAM,eAAe,CAAC;AAE3C,OAAO,EAAE,YAAY,EAAE,MAAM,iBAAiB,CAAC;AAE/C,MAAM,UAAU,eAAe,CAAI,KAAqB,EAAE,SAAwB;IAChF,OAAO,IAAI,UAAU,CAAI,UAAA,UAAU;QACjC,IAAM,GAAG,GAAG,IAAI,YAAY,EAAE,CAAC;QAC/B,GAAG,CAAC,GAAG,CAAC,SAAS,CAAC,QAAQ,CAAC,cAAM,OAAA,KAAK,CAAC,IAAI,CACzC,UAAA,KAAK;YACH,GAAG,CAAC,GAAG,CAAC,SAAS,CAAC,QAAQ,CAAC;gBACzB,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;gBACvB,GAAG,CAAC,GAAG,CAAC,SAAS,CAAC,QAAQ,CAAC,cAAM,OAAA,UAAU,CAAC,QAAQ,EAAE,EAArB,CAAqB,CAAC,CAAC,CAAC;YAC3D,CAAC,CAAC,CAAC,CAAC;QACN,CAAC,EACD,UAAA,GAAG;YACD,GAAG,CAAC,GAAG,CAAC,SAAS,CAAC,QAAQ,CAAC,cAAM,OAAA,UAAU,CAAC,KAAK,CAAC,GAAG,CAAC,EAArB,CAAqB,CAAC,CAAC,CAAC;QAC3D,CAAC,CACF,EAVgC,CAUhC,CAAC,CAAC,CAAC;QACJ,OAAO,GAAG,CAAC;IACb,CAAC,CAAC,CAAC;AACL,CAAC"}
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduled.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduled.js
new file mode 100644
index 00000000..52845751
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduled.js
@@ -0,0 +1,27 @@
+/** PURE_IMPORTS_START _scheduleObservable,_schedulePromise,_scheduleArray,_scheduleIterable,_util_isInteropObservable,_util_isPromise,_util_isArrayLike,_util_isIterable PURE_IMPORTS_END */
+import { scheduleObservable } from './scheduleObservable';
+import { schedulePromise } from './schedulePromise';
+import { scheduleArray } from './scheduleArray';
+import { scheduleIterable } from './scheduleIterable';
+import { isInteropObservable } from '../util/isInteropObservable';
+import { isPromise } from '../util/isPromise';
+import { isArrayLike } from '../util/isArrayLike';
+import { isIterable } from '../util/isIterable';
+export function scheduled(input, scheduler) {
+ if (input != null) {
+ if (isInteropObservable(input)) {
+ return scheduleObservable(input, scheduler);
+ }
+ else if (isPromise(input)) {
+ return schedulePromise(input, scheduler);
+ }
+ else if (isArrayLike(input)) {
+ return scheduleArray(input, scheduler);
+ }
+ else if (isIterable(input) || typeof input === 'string') {
+ return scheduleIterable(input, scheduler);
+ }
+ }
+ throw new TypeError((input !== null && typeof input || input) + ' is not observable');
+}
+//# sourceMappingURL=scheduled.js.map
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduled.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduled.js.map
new file mode 100644
index 00000000..d4e76f87
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm5/internal/scheduled/scheduled.js.map
@@ -0,0 +1 @@
+{"version":3,"file":"scheduled.js","sources":["../../../src/internal/scheduled/scheduled.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,kBAAkB,EAAE,MAAM,sBAAsB,CAAC;AAC1D,OAAO,EAAE,eAAe,EAAE,MAAM,mBAAmB,CAAC;AACpD,OAAO,EAAE,aAAa,EAAE,MAAM,iBAAiB,CAAC;AAChD,OAAO,EAAE,gBAAgB,EAAE,MAAM,oBAAoB,CAAC;AAEtD,OAAO,EAAE,mBAAmB,EAAE,MAAM,6BAA6B,CAAC;AAClE,OAAO,EAAE,SAAS,EAAE,MAAM,mBAAmB,CAAC;AAC9C,OAAO,EAAE,WAAW,EAAE,MAAM,qBAAqB,CAAC;AAClD,OAAO,EAAE,UAAU,EAAE,MAAM,oBAAoB,CAAC;AAahD,MAAM,UAAU,SAAS,CAAI,KAAyB,EAAE,SAAwB;IAC9E,IAAI,KAAK,IAAI,IAAI,EAAE;QACjB,IAAI,mBAAmB,CAAC,KAAK,CAAC,EAAE;YAC9B,OAAO,kBAAkB,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SAC7C;aAAM,IAAI,SAAS,CAAC,KAAK,CAAC,EAAE;YAC3B,OAAO,eAAe,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SAC1C;aAAM,IAAI,WAAW,CAAC,KAAK,CAAC,EAAE;YAC7B,OAAO,aAAa,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SACxC;aAAO,IAAI,UAAU,CAAC,KAAK,CAAC,IAAI,OAAO,KAAK,KAAK,QAAQ,EAAE;YAC1D,OAAO,gBAAgB,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SAC3C;KACF;IAED,MAAM,IAAI,SAAS,CAAC,CAAC,KAAK,KAAK,IAAI,IAAI,OAAO,KAAK,IAAI,KAAK,CAAC,GAAG,oBAAoB,CAAC,CAAC;AACxF,CAAC"}