summaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/subscribeOn.ts
diff options
context:
space:
mode:
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/subscribeOn.ts')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/subscribeOn.ts33
1 files changed, 0 insertions, 33 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/subscribeOn.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/subscribeOn.ts
deleted file mode 100644
index 2cae92d90f..0000000000
--- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/subscribeOn.ts
+++ /dev/null
@@ -1,33 +0,0 @@
-import { Operator } from '../Operator';
-import { Subscriber } from '../Subscriber';
-import { Observable } from '../Observable';
-import { SubscribeOnObservable } from '../observable/SubscribeOnObservable';
-import { MonoTypeOperatorFunction, SchedulerLike, TeardownLogic } from '../types';
-
-/**
- * Asynchronously subscribes Observers to this Observable on the specified {@link SchedulerLike}.
- *
- * ![](subscribeOn.png)
- *
- * @param {SchedulerLike} scheduler - The {@link SchedulerLike} to perform subscription actions on.
- * @return {Observable<T>} The source Observable modified so that its subscriptions happen on the specified {@link SchedulerLike}.
- .
- * @method subscribeOn
- * @owner Observable
- */
-export function subscribeOn<T>(scheduler: SchedulerLike, delay: number = 0): MonoTypeOperatorFunction<T> {
- return function subscribeOnOperatorFunction(source: Observable<T>): Observable<T> {
- return source.lift(new SubscribeOnOperator<T>(scheduler, delay));
- };
-}
-
-class SubscribeOnOperator<T> implements Operator<T, T> {
- constructor(private scheduler: SchedulerLike,
- private delay: number) {
- }
- call(subscriber: Subscriber<T>, source: any): TeardownLogic {
- return new SubscribeOnObservable<T>(
- source, this.delay, this.scheduler
- ).subscribe(subscriber);
- }
-}