Organize Imports - Migrate to rx.schedulers for src/main

Author: benjchristensen

rxjava-core/src/main/java/rx/Observable.java

@@ -27,7 +27,6 @@
 import java.util.concurrent.Future;
 import java.util.concurrent.TimeUnit;
 
-import rx.concurrency.Schedulers;
 import rx.joins.Pattern2;
 import rx.joins.Plan0;
 import rx.observables.BlockingObservable;
@@ -109,6 +108,7 @@
 import rx.plugins.RxJavaErrorHandler;
 import rx.plugins.RxJavaObservableExecutionHook;
 import rx.plugins.RxJavaPlugins;
+import rx.schedulers.Schedulers;
 import rx.subjects.AsyncSubject;
 import rx.subjects.PublishSubject;
 import rx.subjects.ReplaySubject;

rxjava-core/src/main/java/rx/operators/OperationBuffer.java

@@ -24,7 +24,7 @@
 import rx.Observer;
 import rx.Scheduler;
 import rx.Subscription;
-import rx.concurrency.Schedulers;
+import rx.schedulers.Schedulers;
 import rx.subscriptions.CompositeSubscription;
 import rx.util.functions.Func0;
 import rx.util.functions.Func1;

rxjava-core/src/main/java/rx/operators/OperationDebounce.java

@@ -23,7 +23,7 @@
 import rx.Observer;
 import rx.Scheduler;
 import rx.Subscription;
-import rx.concurrency.Schedulers;
+import rx.schedulers.Schedulers;
 import rx.util.functions.Action0;
 import rx.util.functions.Func1;
 

rxjava-core/src/main/java/rx/operators/OperationDoOnEach.java

@@ -16,8 +16,8 @@
 package rx.operators;
 
 import rx.Observable;
-import rx.Observer;
 import rx.Observable.OnSubscribeFunc;
+import rx.Observer;
 import rx.Subscription;
 
 /**

rxjava-core/src/main/java/rx/operators/OperationGroupByUntil.java

@@ -19,6 +19,7 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+
 import rx.Observable;
 import rx.Observable.OnSubscribeFunc;
 import rx.Observer;

rxjava-core/src/main/java/rx/operators/OperationGroupJoin.java

@@ -19,6 +19,7 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+
 import rx.Observable;
 import rx.Observable.OnSubscribeFunc;
 import rx.Observer;

rxjava-core/src/main/java/rx/operators/OperationInterval.java

@@ -21,7 +21,7 @@
 import rx.Observer;
 import rx.Scheduler;
 import rx.Subscription;
-import rx.concurrency.Schedulers;
+import rx.schedulers.Schedulers;
 import rx.subscriptions.Subscriptions;
 import rx.util.functions.Action0;
 

rxjava-core/src/main/java/rx/operators/OperationJoin.java

@@ -17,6 +17,7 @@
 
 import java.util.HashMap;
 import java.util.Map;
+
 import rx.Observable;
 import rx.Observable.OnSubscribeFunc;
 import rx.Observer;

rxjava-core/src/main/java/rx/operators/OperationJoinPatterns.java

@@ -20,6 +20,7 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+
 import rx.Observable;
 import rx.Observable.OnSubscribeFunc;
 import rx.Observer;
@@ -29,11 +30,9 @@
 import rx.joins.Pattern1;
 import rx.joins.Pattern2;
 import rx.joins.Plan0;
-import rx.subjects.PublishSubject;
 import rx.subscriptions.CompositeSubscription;
 import rx.util.functions.Action1;
 import rx.util.functions.Func1;
-import rx.util.functions.Func2;
 
 /**
  * Join patterns: And, Then, When.

rxjava-core/src/main/java/rx/operators/OperationObserveOn.java

@@ -24,10 +24,9 @@
 import rx.Observer;
 import rx.Scheduler;
 import rx.Subscription;
-import rx.concurrency.CurrentThreadScheduler;
-import rx.concurrency.ImmediateScheduler;
+import rx.schedulers.CurrentThreadScheduler;
+import rx.schedulers.ImmediateScheduler;
 import rx.subscriptions.CompositeSubscription;
-import rx.subscriptions.SerialSubscription;
 import rx.subscriptions.Subscriptions;
 import rx.util.functions.Action0;
 import rx.util.functions.Action1;