unchecked warnings (#393)

unchecked warnings issued by the compiler

Author: qweek

rsocket-core/src/jmh/java/io/rsocket/RSocketPerf.java

@@ -16,8 +16,8 @@
 
 package io.rsocket;
 
+import io.rsocket.RSocketFactory.Start;
 import io.rsocket.perfutil.TestDuplexConnection;
-import io.rsocket.transport.ServerTransport;
 import io.rsocket.util.PayloadImpl;
 import java.nio.ByteBuffer;
 import java.nio.charset.StandardCharsets;
@@ -90,7 +90,7 @@ public static class Input {
     static final TestDuplexConnection serverConnection =
         new TestDuplexConnection(clientReceive, serverReceive);
 
-    static final Object server =
+    static final Start<Closeable> server =
         RSocketFactory.receive()
             .acceptor(
                 (setup, sendingSocket) -> {
@@ -135,27 +135,26 @@ public Mono<Void> onClose() {
                   return Mono.just(rSocket);
                 })
             .transport(
-                (ServerTransport)
-                    acceptor -> {
-                      Closeable closeable =
-                          new Closeable() {
-                            MonoProcessor<Void> onClose = MonoProcessor.create();
-
-                            @Override
-                            public Mono<Void> close() {
-                              return Mono.empty().doFinally(s -> onClose.onComplete()).then();
-                            }
-
-                            @Override
-                            public Mono<Void> onClose() {
-                              return onClose;
-                            }
-                          };
-
-                      acceptor.apply(serverConnection).subscribe();
-
-                      return Mono.just(closeable);
-                    });
+                acceptor -> {
+                  Closeable closeable =
+                      new Closeable() {
+                        MonoProcessor<Void> onClose = MonoProcessor.create();
+
+                        @Override
+                        public Mono<Void> close() {
+                          return Mono.empty().doFinally(s -> onClose.onComplete()).then();
+                        }
+
+                        @Override
+                        public Mono<Void> onClose() {
+                          return onClose;
+                        }
+                      };
+
+                  acceptor.apply(serverConnection).subscribe();
+
+                  return Mono.just(closeable);
+                });
 
     Subscriber blackHoleSubscriber;
 

rsocket-core/src/test/java/io/rsocket/fragmentation/FragmentationDuplexConnectionTest.java

@@ -121,7 +121,7 @@ public void testReassembleFragmentFrame() {
         Frame.Request.from(1024, FrameType.REQUEST_RESPONSE, new PayloadImpl(data, metadata), 1);
     FrameFragmenter frameFragmenter = new FrameFragmenter(2);
     Flux<Frame> fragmentedFrames = frameFragmenter.fragment(frame);
-    EmitterProcessor processor = EmitterProcessor.create(128);
+    EmitterProcessor<Frame> processor = EmitterProcessor.create(128);
     DuplexConnection mockConnection = mock(DuplexConnection.class);
     when(mockConnection.receive()).then(answer -> processor);
 

rsocket-core/src/test/java/io/rsocket/test/util/TestSubscriber.java

@@ -14,7 +14,8 @@ public static <T> Subscriber<T> create() {
   }
 
   public static <T> Subscriber<T> create(long initialRequest) {
-    Subscriber mock = mock(Subscriber.class);
+    @SuppressWarnings("unchecked")
+    Subscriber<T> mock = mock(Subscriber.class);
 
     Mockito.doAnswer(
             invocation -> {
@@ -34,7 +35,8 @@ public static Payload anyPayload() {
   }
 
   public static Subscriber<Payload> createCancelling() {
-    Subscriber mock = mock(Subscriber.class);
+    @SuppressWarnings("unchecked")
+    Subscriber<Payload> mock = mock(Subscriber.class);
 
     Mockito.doAnswer(
             invocation -> {