optimizes/fixes UnboundedProcessor

Signed-off-by: Oleh Dokuka <[email protected]>

Author: OlegDokuka

rsocket-core/src/main/java/io/rsocket/internal/BaseDuplexConnection.java

@@ -8,7 +8,7 @@
 public abstract class BaseDuplexConnection implements DuplexConnection {
   protected MonoProcessor<Void> onClose = MonoProcessor.create();
 
-  protected UnboundedProcessor<ByteBuf> sender = new UnboundedProcessor<>();
+  protected UnboundedProcessor sender = new UnboundedProcessor();
 
   public BaseDuplexConnection() {
     onClose.doFinally(s -> doOnClose()).subscribe();