aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/rxjs/dist/cjs/internal/operators/timeoutWith.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/rxjs/dist/cjs/internal/operators/timeoutWith.js')
-rw-r--r--node_modules/rxjs/dist/cjs/internal/operators/timeoutWith.js35
1 files changed, 35 insertions, 0 deletions
diff --git a/node_modules/rxjs/dist/cjs/internal/operators/timeoutWith.js b/node_modules/rxjs/dist/cjs/internal/operators/timeoutWith.js
new file mode 100644
index 0000000..5811d86
--- /dev/null
+++ b/node_modules/rxjs/dist/cjs/internal/operators/timeoutWith.js
@@ -0,0 +1,35 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.timeoutWith = void 0;
+var async_1 = require("../scheduler/async");
+var isDate_1 = require("../util/isDate");
+var timeout_1 = require("./timeout");
+function timeoutWith(due, withObservable, scheduler) {
+ var first;
+ var each;
+ var _with;
+ scheduler = scheduler !== null && scheduler !== void 0 ? scheduler : async_1.async;
+ if (isDate_1.isValidDate(due)) {
+ first = due;
+ }
+ else if (typeof due === 'number') {
+ each = due;
+ }
+ if (withObservable) {
+ _with = function () { return withObservable; };
+ }
+ else {
+ throw new TypeError('No observable provided to switch to');
+ }
+ if (first == null && each == null) {
+ throw new TypeError('No timeout provided.');
+ }
+ return timeout_1.timeout({
+ first: first,
+ each: each,
+ scheduler: scheduler,
+ with: _with,
+ });
+}
+exports.timeoutWith = timeoutWith;
+//# sourceMappingURL=timeoutWith.js.map \ No newline at end of file
send patches to the email below
yukais@pinapelz.com
include the subject [PATCH repo_name]
pinapelz.com
homepage