Rename RxJavaSchedulers to RxJavaDefaultSchedulers

Clearer semantic naming.

Author: benjchristensen

rxjava-core/src/main/java/rx/plugins/RxJavaSchedulers.java renamed to rxjava-core/src/main/java/rx/plugins/RxJavaDefaultSchedulers.java

@@ -24,20 +24,20 @@
  * See {@link RxJavaPlugins} or the RxJava GitHub Wiki for information on configuring plugins: <a
  * href="https://github.com/Netflix/RxJava/wiki/Plugins">https://github.com/Netflix/RxJava/wiki/Plugins</a>.
  */
-public abstract class RxJavaSchedulers {
+public abstract class RxJavaDefaultSchedulers {
 
     /**
      * Factory of Scheduler to return from {@link Schedulers.computation()} or null if default should be used.
      */
-    public abstract Func0<Scheduler> getComputationScheduler();
+    public abstract Func0<Scheduler> getComputationSchedulerFactory();
 
     /**
      * Factory of Scheduler to return from {@link Schedulers.io()} or null if default should be used.
      */
-    public abstract Func0<Scheduler> getIOScheduler();
+    public abstract Func0<Scheduler> getIOSchedulerFactory();
 
     /**
      * Factory of Scheduler to return from {@link Schedulers.newThread()} or null if default should be used.
      */
-    public abstract Func0<Scheduler> getNewThreadScheduler();
+    public abstract Func0<Scheduler> getNewThreadSchedulerFactory();
 }

rxjava-core/src/main/java/rx/plugins/RxJavaSchedulersDefault.java renamed to rxjava-core/src/main/java/rx/plugins/RxJavaDefaultSchedulersDefault.java

@@ -23,23 +23,23 @@
  * 
  * @ExcludeFromJavadoc
  */
-public class RxJavaSchedulersDefault extends RxJavaSchedulers {
+public class RxJavaDefaultSchedulersDefault extends RxJavaDefaultSchedulers {
 
-    private static RxJavaSchedulersDefault INSTANCE = new RxJavaSchedulersDefault();
+    private static RxJavaDefaultSchedulersDefault INSTANCE = new RxJavaDefaultSchedulersDefault();
 
-    public Func0<Scheduler> getComputationScheduler() {
+    public Func0<Scheduler> getComputationSchedulerFactory() {
         return null;
     }
 
-    public Func0<Scheduler> getIOScheduler() {
+    public Func0<Scheduler> getIOSchedulerFactory() {
         return null;
     }
 
-    public Func0<Scheduler> getNewThreadScheduler() {
+    public Func0<Scheduler> getNewThreadSchedulerFactory() {
         return null;
     }
 
-    public static RxJavaSchedulers getInstance() {
+    public static RxJavaDefaultSchedulers getInstance() {
         return INSTANCE;
     }
 

rxjava-core/src/main/java/rx/plugins/RxJavaPlugins.java

@@ -31,7 +31,7 @@ public class RxJavaPlugins {
 
     private final AtomicReference<RxJavaErrorHandler> errorHandler = new AtomicReference<RxJavaErrorHandler>();
     private final AtomicReference<RxJavaObservableExecutionHook> observableExecutionHook = new AtomicReference<RxJavaObservableExecutionHook>();
-    private final AtomicReference<RxJavaSchedulers> schedulerOverrides = new AtomicReference<RxJavaSchedulers>();
+    private final AtomicReference<RxJavaDefaultSchedulers> schedulerOverrides = new AtomicReference<RxJavaDefaultSchedulers>();
 
     public static RxJavaPlugins getInstance() {
         return INSTANCE;
@@ -152,39 +152,39 @@ private static Object getPluginImplementationViaProperty(Class<?> pluginClass) {
     }
 
     /**
-     * Retrieve instance of {@link RxJavaSchedulers} to use based on order of precedence as defined in {@link RxJavaPlugins} class header.
+     * Retrieve instance of {@link RxJavaDefaultSchedulers} to use based on order of precedence as defined in {@link RxJavaPlugins} class header.
      * <p>
-     * Override default by using {@link #registerSchedulers(RxJavaSchedulers)} or setting property: <code>rxjava.plugin.RxJavaDefaultSchedulers.implementation</code> with the full
+     * Override default by using {@link #registerDefaultSchedulers(RxJavaDefaultSchedulers)} or setting property: <code>rxjava.plugin.RxJavaDefaultSchedulers.implementation</code> with the full
      * classname to
      * load.
      * 
      * @return {@link RxJavaErrorHandler} implementation to use
      */
-    public RxJavaSchedulers getSchedulers() {
+    public RxJavaDefaultSchedulers getDefaultSchedulers() {
         if (schedulerOverrides.get() == null) {
             // check for an implementation from System.getProperty first
-            Object impl = getPluginImplementationViaProperty(RxJavaSchedulers.class);
+            Object impl = getPluginImplementationViaProperty(RxJavaDefaultSchedulers.class);
             if (impl == null) {
                 // nothing set via properties so initialize with default 
-                schedulerOverrides.compareAndSet(null, RxJavaSchedulersDefault.getInstance());
+                schedulerOverrides.compareAndSet(null, RxJavaDefaultSchedulersDefault.getInstance());
                 // we don't return from here but call get() again in case of thread-race so the winner will always get returned
             } else {
                 // we received an implementation from the system property so use it
-                schedulerOverrides.compareAndSet(null, (RxJavaSchedulers) impl);
+                schedulerOverrides.compareAndSet(null, (RxJavaDefaultSchedulers) impl);
             }
         }
         return schedulerOverrides.get();
     }
 
     /**
-     * Register a {@link RxJavaSchedulers} implementation as a global override of any injected or default implementations.
+     * Register a {@link RxJavaDefaultSchedulers} implementation as a global override of any injected or default implementations.
      * 
      * @param impl
-     *            {@link RxJavaSchedulers} implementation
+     *            {@link RxJavaDefaultSchedulers} implementation
      * @throws IllegalStateException
      *             if called more than once or after the default was initialized (if usage occurs before trying to register)
      */
-    public void registerSchedulers(RxJavaSchedulers impl) {
+    public void registerDefaultSchedulers(RxJavaDefaultSchedulers impl) {
         if (!schedulerOverrides.compareAndSet(null, impl)) {
             throw new IllegalStateException("Another strategy was already registered: " + schedulerOverrides.get());
         }

rxjava-core/src/main/java/rx/schedulers/NewThreadScheduler.java

@@ -46,9 +46,14 @@ public Thread newThread(Runnable r) {
         }
     };
 
+    @Deprecated
     public static NewThreadScheduler getInstance() {
         return INSTANCE;
     }
+    
+    /* package */ static NewThreadScheduler instance() {
+        return INSTANCE;
+    }
 
     private NewThreadScheduler() {
 

rxjava-core/src/main/java/rx/schedulers/Schedulers.java

@@ -38,7 +38,7 @@ public class Schedulers {
     private static final Schedulers INSTANCE = new Schedulers();
 
     private Schedulers() {
-        Func0<Scheduler> c = RxJavaPlugins.getInstance().getSchedulers().getComputationScheduler();
+        Func0<Scheduler> c = RxJavaPlugins.getInstance().getDefaultSchedulers().getComputationSchedulerFactory();
         if (c != null) {
             computationScheduler = c;
         } else {
@@ -52,7 +52,7 @@ public Scheduler call() {
             };
         }
 
-        Func0<Scheduler> io = RxJavaPlugins.getInstance().getSchedulers().getIOScheduler();
+        Func0<Scheduler> io = RxJavaPlugins.getInstance().getDefaultSchedulers().getIOSchedulerFactory();
         if (io != null) {
             ioScheduler = io;
         } else {
@@ -66,15 +66,15 @@ public Scheduler call() {
             };
         }
 
-        Func0<Scheduler> nt = RxJavaPlugins.getInstance().getSchedulers().getNewThreadScheduler();
+        Func0<Scheduler> nt = RxJavaPlugins.getInstance().getDefaultSchedulers().getNewThreadSchedulerFactory();
         if (nt != null) {
             newThreadScheduler = nt;
         } else {
             newThreadScheduler = new Func0<Scheduler>() {
 
                 @Override
                 public Scheduler call() {
-                    return NewThreadScheduler.getInstance();
+                    return NewThreadScheduler.instance();
                 }
 
             };