Merge pull request #1749 from benjchristensen/buffer-empty

BufferUntilSubscriber EmptyObserver

Author: benjchristensen

src/main/java/rx/internal/operators/BufferUntilSubscriber.java

@@ -90,9 +90,10 @@ public OnSubscribeAction(State<T> state) {
         public void call(final Subscriber<? super T> s) {
             if (state.casObserverRef(null, s)) {
                 s.add(Subscriptions.create(new Action0() {
+                    @SuppressWarnings("unchecked")
                     @Override
                     public void call() {
-                        state.observerRef = Observers.empty();
+                        state.observerRef = EMPTY_OBSERVER;
                     }
                 }));
                 boolean win = false;
@@ -184,4 +185,25 @@ public void onNext(T t) {
             emit(state.nl.next(t));
         }
     }
+    
+    @SuppressWarnings("rawtypes")
+    private final static Observer EMPTY_OBSERVER = new Observer() {
+
+        @Override
+        public void onCompleted() {
+            
+        }
+
+        @Override
+        public void onError(Throwable e) {
+            
+        }
+
+        @Override
+        public void onNext(Object t) {
+            
+        }
+        
+    };
+    
 }