Subscribers/Observers.empty()

Author: benjchristensen

rxjava-core/src/main/java/rx/observers/Observers.java

@@ -1,34 +1,35 @@
 package rx.observers;
 
 import rx.Observer;
+import rx.Subscriber;
 import rx.util.OnErrorNotImplementedException;
 import rx.util.functions.Action0;
 import rx.util.functions.Action1;
 
 public class Observers {
 
-    /**
-     * Create an empty Observer that ignores all events.
-     */
-    public static final <T> Observer<T> create() {
-        return new Observer<T>() {
+    private static final Observer<Object> EMPTY = new Observer<Object>() {
 
-            @Override
-            public final void onCompleted() {
-                // do nothing
-            }
+        @Override
+        public final void onCompleted() {
+            // do nothing
+        }
 
-            @Override
-            public final void onError(Throwable e) {
-                throw new OnErrorNotImplementedException(e);
-            }
+        @Override
+        public final void onError(Throwable e) {
+            throw new OnErrorNotImplementedException(e);
+        }
 
-            @Override
-            public final void onNext(T args) {
-                // do nothing
-            }
+        @Override
+        public final void onNext(Object args) {
+            // do nothing
+        }
 
-        };
+    };
+
+    @SuppressWarnings("unchecked")
+    public static <T> Observer<T> empty() {
+        return (Observer<T>) EMPTY;
     }
 
     /**

rxjava-core/src/main/java/rx/observers/Subscribers.java

@@ -8,6 +8,30 @@
 
 public class Subscribers {
 
+    private static final Subscriber<Object> EMPTY = new Subscriber<Object>() {
+
+        @Override
+        public final void onCompleted() {
+            // do nothing
+        }
+
+        @Override
+        public final void onError(Throwable e) {
+            throw new OnErrorNotImplementedException(e);
+        }
+
+        @Override
+        public final void onNext(Object args) {
+            // do nothing
+        }
+
+    };
+
+    @SuppressWarnings("unchecked")
+    public static <T> Subscriber<T> empty() {
+        return (Subscriber<T>) EMPTY;
+    }
+
     public static <T> Subscriber<T> from(final Observer<? super T> o) {
         return new Subscriber<T>() {
 
@@ -29,30 +53,6 @@ public void onNext(T t) {
         };
     }
 
-    /**
-     * Create an empty Subscriber that ignores all events.
-     */
-    public static final <T> Subscriber<T> create() {
-        return new Subscriber<T>() {
-
-            @Override
-            public final void onCompleted() {
-                // do nothing
-            }
-
-            @Override
-            public final void onError(Throwable e) {
-                throw new OnErrorNotImplementedException(e);
-            }
-
-            @Override
-            public final void onNext(T args) {
-                // do nothing
-            }
-
-        };
-    }
-
     /**
      * Create an Subscriber that receives `onNext` and ignores `onError` and `onCompleted`.
      */

rxjava-core/src/main/java/rx/observers/TestObserver.java

@@ -28,7 +28,6 @@
  */
 public class TestObserver<T> implements Observer<T> {
 
-    private final Observer<Object> EMPTY = new EmptyObserver<Object>();
 
     private final Observer<T> delegate;
     private final ArrayList<T> onNextEvents = new ArrayList<T>();
@@ -39,9 +38,8 @@ public TestObserver(Observer<T> delegate) {
         this.delegate = delegate;
     }
 
-    @SuppressWarnings("unchecked")
     public TestObserver() {
-        this.delegate = (Observer<T>) EMPTY;
+        this.delegate = Observers.empty();
     }
 
     @Override

rxjava-core/src/main/java/rx/observers/TestSubscriber.java

@@ -26,8 +26,6 @@
  */
 public class TestSubscriber<T> extends Subscriber<T> {
 
-    private final Subscriber<Object> EMPTY = Subscribers.create();
-
     private final TestObserver<T> testObserver;
 
     public TestSubscriber(Subscriber<T> delegate) {
@@ -38,9 +36,8 @@ public TestSubscriber(Observer<T> delegate) {
         this.testObserver = new TestObserver<T>(delegate);
     }
 
-    @SuppressWarnings("unchecked")
     public TestSubscriber() {
-        this.testObserver = new TestObserver<T>((Subscriber<T>) EMPTY);
+        this.testObserver = new TestObserver<T>(Subscribers.<T>empty());
     }
 
     @Override

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

@@ -37,7 +37,7 @@ public Subscriber<? super T1> call(final Subscriber<? super R> subscriber) {
         try {
             if (!iterator.hasNext()) {
                 subscriber.onCompleted();
-                return Subscribers.create();
+                return Subscribers.empty();
             }
         } catch (Throwable e) {
             subscriber.onError(e);