More Nono operators.

Author: akarnokd

Diff for: src/main/java/hu/akarnokd/rxjava2/basetypes/BasicEmptyQueueSubscription.java

@@ -32,27 +32,27 @@ public final boolean offer(Void e) {
     public final boolean offer(Void v1, Void v2) {
         throw new UnsupportedOperationException("Should not be called!");
     }
-    
+
     @Override
     public final void clear() {
         // no-op
     }
-    
+
     @Override
     public final boolean isEmpty() {
         return true;
     }
-    
+
     @Override
     public final Void poll() throws Exception {
         return null;
     }
-    
+
     @Override
     public final void request(long n) {
         // no-op
     }
-    
+
     @Override
     public final int requestFusion(int mode) {
         return mode & ASYNC;

Diff for: src/main/java/hu/akarnokd/rxjava2/basetypes/BasicNonoSubscriber.java

@@ -23,7 +23,7 @@
 /**
  * Basic subscriber that supports queue fusion and defaults onSubscribe, onNext and cancel.
  */
-public abstract class BasicNonoSubscriber extends BasicEmptyQueueSubscription implements Subscriber<Void> {
+public abstract class BasicNonoSubscriber extends BasicEmptyQueueSubscription implements Subscriber<Object> {
 
     protected final Subscriber<? super Void> actual;
 
@@ -43,7 +43,7 @@ public void onSubscribe(Subscription s) {
     }
 
     @Override
-    public final void onNext(Void t) {
+    public final void onNext(Object t) {
         // never called
     }
 

Diff for: src/main/java/hu/akarnokd/rxjava2/basetypes/BasicRefNonoSubscriber.java

@@ -55,27 +55,26 @@ public void cancel() {
         s.cancel();
     }
 
-    
     @Override
     public final void clear() {
         // no-op
     }
-    
+
     @Override
     public final boolean isEmpty() {
         return true;
     }
-    
+
     @Override
     public final Void poll() throws Exception {
         return null;
     }
-    
+
     @Override
     public final void request(long n) {
         // no-op
     }
-    
+
     @Override
     public final int requestFusion(int mode) {
         return mode & ASYNC;