chakra-coder
diff --git a/‎build.gradle
Lines changed: 1 addition & 0 deletions b/‎build.gradle
Lines changed: 1 addition & 0 deletions
diff --git a/‎rsocket-core/src/main/java/io/rsocket/RSocketClient.java
Lines changed: 0 additions & 1 deletion b/‎rsocket-core/src/main/java/io/rsocket/RSocketClient.java
Lines changed: 0 additions & 1 deletion
diff --git a/‎rsocket-examples/src/test/java/io/rsocket/integration/IntegrationTest.java
Lines changed: 1 addition & 1 deletion b/‎rsocket-examples/src/test/java/io/rsocket/integration/IntegrationTest.java
Lines changed: 1 addition & 1 deletion
diff --git a/‎rsocket-spectator/src/main/java/io/rsocket/spectator/SpectatorRSocket.java
Lines changed: 2 additions & 4 deletions b/‎rsocket-spectator/src/main/java/io/rsocket/spectator/SpectatorRSocket.java
Lines changed: 2 additions & 4 deletions
diff --git a/‎rsocket-tck-drivers/src/main/java/io/rsocket/tckdrivers/runner/RunnerRSocket.java
Lines changed: 6 additions & 0 deletions b/‎rsocket-tck-drivers/src/main/java/io/rsocket/tckdrivers/runner/RunnerRSocket.java
Lines changed: 6 additions & 0 deletions
diff --git a/‎rsocket-tck-drivers/src/main/java/io/rsocket/tckdrivers/runner/TckMessageUtil.java
Lines changed: 2 additions & 0 deletions b/‎rsocket-tck-drivers/src/main/java/io/rsocket/tckdrivers/runner/TckMessageUtil.java
Lines changed: 2 additions & 0 deletions
diff --git a/‎rsocket-test/src/main/java/io/rsocket/test/TestSubscriber.java
Lines changed: 4 additions & 2 deletions b/‎rsocket-test/src/main/java/io/rsocket/test/TestSubscriber.java
Lines changed: 4 additions & 2 deletions
@@ -40,6 +40,7 @@ subprojects {
     compileJava {
         sourceCompatibility = 1.8
         targetCompatibility = 1.8
+        options.compilerArgs << "-Xlint:deprecation" // << "-Xlint:unchecked"
     }
 
     ext {
 
@@ -408,7 +408,6 @@ private void handleStreamZero(FrameType type, Frame frame) {
     }
   }
 
-  @SuppressWarnings("unchecked")
   private void handleFrame(int streamId, FrameType type, Frame frame) {
     Subscriber<Payload> receiver;
     synchronized (this) {
 
@@ -149,7 +149,7 @@ public void testRequest() {
 
   @Test
   public void testStream() throws Exception {
-    Subscriber subscriber = TestSubscriber.createCancelling();
+    Subscriber<Payload> subscriber = TestSubscriber.createCancelling();
     client.requestStream(new PayloadImpl("start")).subscribe(subscriber);
 
     verify(subscriber).onSubscribe(any());
 
@@ -21,7 +21,6 @@
 import com.netflix.spectator.api.Timer;
 import io.rsocket.Payload;
 import io.rsocket.RSocket;
-import java.lang.reflect.Array;
 import java.util.concurrent.TimeUnit;
 import org.reactivestreams.Publisher;
 import reactor.core.publisher.Flux;
@@ -99,16 +98,15 @@ public SpectatorRSocket(Registry registry, RSocket delegate, String... tags) {
         registry.timer("reactiveSocketStats", concatenate(tags, "metadataPush", "timer"));
   }
 
-  static <T> T[] concatenate(T[] a, T... b) {
+  private static String[] concatenate(String[] a, String... b) {
     if (a == null || a.length == 0) {
       return b;
     }
 
     int aLen = a.length;
     int bLen = b.length;
 
-    @SuppressWarnings("unchecked")
-    T[] c = (T[]) Array.newInstance(a.getClass().getComponentType(), aLen + bLen);
+    String[] c = new String[aLen + bLen];
     System.arraycopy(a, 0, c, 0, aLen);
     System.arraycopy(b, 0, c, aLen, bLen);
 
 
@@ -27,8 +27,11 @@ public RunnerRSocket() {}
   @Override
   public Mono<Payload> requestResponse(Payload payload) {
     Map<String, Object> clientTest = parseTCKMessage(payload, "runnerExecuteTest");
+    @SuppressWarnings("unchecked")
     Map<String, Object> setup = (Map<String, Object>) clientTest.get("setup");
+    @SuppressWarnings("unchecked")
     Map<String, Object> test = (Map<String, Object>) clientTest.get("test");
+    @SuppressWarnings("unchecked")
     Map<String, Object> tck1Definition = (Map<String, Object>) test.get("tck1Definition");
 
     String url = (String) setup.get("url");
@@ -68,8 +71,11 @@ public Mono<Payload> requestResponse(Payload payload) {
   public Flux<Payload> requestStream(Payload payload) {
     Map<String, Object> serverTest = parseTCKMessage(payload, "runnerExecuteTest");
 
+    @SuppressWarnings("unchecked")
     Map<String, Object> setup = (Map<String, Object>) serverTest.get("setup");
+    @SuppressWarnings("unchecked")
     Map<String, Object> test = (Map<String, Object>) serverTest.get("test");
+    @SuppressWarnings("unchecked")
     Map<String, Object> tck1Definition = (Map<String, Object>) test.get("tck1Definition");
 
     // TODO check version
 
@@ -24,7 +24,9 @@ public static String result(Map<String, Object> t) {
   }
 
   public static void printTestRunResults(Map<String, Object> suite) {
+    @SuppressWarnings("unchecked")
     Map<String, Object> setup = (Map<String, Object>) suite.get("setup");
+    @SuppressWarnings("unchecked")
     List<Map<String, Object>> tests = (List<Map<String, Object>>) suite.get("tests");
 
     for (Map<String, Object> t : tests) {
 
@@ -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 -> {