1 files changed, 0 insertions, 52 deletions
diff --git a/node_modules/rxjs/src/internal/scheduler/AsyncScheduler.ts b/node_modules/rxjs/src/internal/scheduler/AsyncScheduler.ts
deleted file mode 100644
index b05e2e3..0000000
--- a/node_modules/rxjs/src/internal/scheduler/AsyncScheduler.ts
+++ /dev/null
@@ -1,52 +0,0 @@
-import { Scheduler } from '../Scheduler';
-import { Action } from './Action';
-import { AsyncAction } from './AsyncAction';
-import { TimerHandle } from './timerHandle';
-
-export class AsyncScheduler extends Scheduler {
-  public actions: Array<AsyncAction<any>> = [];
-  /**
-   * A flag to indicate whether the Scheduler is currently executing a batch of
-   * queued actions.
-   * @internal
-   */
-  public _active: boolean = false;
-  /**
-   * An internal ID used to track the latest asynchronous task such as those
-   * coming from `setTimeout`, `setInterval`, `requestAnimationFrame`, and
-   * others.
-   * @internal
-   */
-  public _scheduled: TimerHandle | undefined;
-
-  constructor(SchedulerAction: typeof Action, now: () => number = Scheduler.now) {
-    super(SchedulerAction, now);
-  }
-
-  public flush(action: AsyncAction<any>): void {
-    const { actions } = this;
-
-    if (this._active) {
-      actions.push(action);
-      return;
-    }
-
-    let error: any;
-    this._active = true;
-
-    do {
-      if ((error = action.execute(action.state, action.delay))) {
-        break;
-      }
-    } while ((action = actions.shift()!)); // exhaust the scheduler queue
-
-    this._active = false;
-
-    if (error) {
-      while ((action = actions.shift()!)) {
-        action.unsubscribe();
-      }
-      throw error;
-    }
-  }
-}