Bens root removal service

src/internal/observable/dom/WebSocketSubject.ts

@@ -3,7 +3,6 @@ import { Subscriber } from '../../Subscriber';
 import { Observable } from '../../Observable';
 import { Subscription } from '../../Subscription';
 import { Operator } from '../../Operator';
-import { root } from '../..//util/root';
 import { ReplaySubject } from '../../ReplaySubject';
 import { Observer, NextObserver } from '../../types';
 import { tryCatch } from '../..//util/tryCatch';
@@ -90,7 +89,7 @@ export class WebSocketSubject<T> extends AnonymousSubject<T> {
       super(destination, <Observable<T>> urlConfigOrSource);
     } else {
       super();
-      this.WebSocketCtor = root.WebSocket;
+      this.WebSocketCtor = WebSocket;
       this._output = new Subject<T>();
       if (typeof urlConfigOrSource === 'string') {
         this.url = urlConfigOrSource;

src/internal/scheduler/AsyncAction.ts

@@ -1,4 +1,3 @@
-import { root } from '../util/root';
 import { Action } from './Action';
 import { Subscription } from '../Subscription';
 import { AsyncScheduler } from './AsyncScheduler';
@@ -69,7 +68,7 @@ export class AsyncAction<T> extends Action<T> {
   }
 
   protected requestAsyncId(scheduler: AsyncScheduler, id?: any, delay: number = 0): any {
-    return root.setInterval(scheduler.flush.bind(scheduler, this), delay);
+    return setInterval(scheduler.flush.bind(scheduler, this), delay);
   }
 
   protected recycleAsyncId(scheduler: AsyncScheduler, id: any, delay: number = 0): any {
@@ -79,7 +78,7 @@ export class AsyncAction<T> extends Action<T> {
     }
     // Otherwise, if the action's delay time is different from the current delay,
     // or the action has been rescheduled before it's executed, clear the interval id
-    return root.clearInterval(id) && undefined || undefined;
+    return clearInterval(id) && undefined || undefined;
   }
 
   /**

src/internal/symbol/rxSubscriber.ts

@@ -1,9 +1,7 @@
-import { root } from '../util/root';
-
-const Symbol: any = root.Symbol;
-
-export const rxSubscriber = (typeof Symbol === 'function' && typeof Symbol.for === 'function') ?
-  Symbol.for('rxSubscriber') : '@@rxSubscriber';
+export const rxSubscriber =
+  (typeof Symbol === 'function' && typeof Symbol.for === 'function')
+    ? Symbol.for('rxSubscriber')
+    : '@@rxSubscriber';
 
 /**
  * @deprecated use rxSubscriber instead

src/internal/util/subscribeToPromise.ts

@@ -1,4 +1,3 @@
-import { root } from './root';
 import { Subscriber } from '../Subscriber';
 
 export const subscribeToPromise = <T>(promise: PromiseLike<T>) => (subscriber: Subscriber<T>) => {
@@ -13,7 +12,7 @@ export const subscribeToPromise = <T>(promise: PromiseLike<T>) => (subscriber: S
   )
   .then(null, (err: any) => {
     // Escaping the Promise trap: globally throw unhandled errors
-    root.setTimeout(() => { throw err; });
+    setTimeout(() => { throw err; });
   });
   return subscriber;
 };