enable artifacts overriding

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

Author: OlegDokuka

bintray.gradle

@@ -25,6 +25,7 @@ if (project.hasProperty('bintrayUser') && project.hasProperty('bintrayKey') &&
 
                 publications = ['maven']
                 publish = true
+                override = true
 
                 pkg {
                     repo = 'RSocket'

rsocket-core/src/test/java/io/rsocket/RSocketClientTerminationTest.java

@@ -2,6 +2,10 @@
 
 import io.rsocket.RSocketClientTest.ClientSocketRule;
 import io.rsocket.util.EmptyPayload;
+import java.nio.channels.ClosedChannelException;
+import java.time.Duration;
+import java.util.Arrays;
+import java.util.function.Function;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -11,16 +15,10 @@
 import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
 
-import java.nio.channels.ClosedChannelException;
-import java.time.Duration;
-import java.util.Arrays;
-import java.util.function.Function;
-
 @RunWith(Parameterized.class)
 public class RSocketClientTerminationTest {
 
-  @Rule
-  public final ClientSocketRule rule = new ClientSocketRule();
+  @Rule public final ClientSocketRule rule = new ClientSocketRule();
   private Function<RSocket, ? extends Publisher<?>> interaction;
 
   public RSocketClientTerminationTest(Function<RSocket, ? extends Publisher<?>> interaction) {
@@ -31,9 +29,7 @@ public RSocketClientTerminationTest(Function<RSocket, ? extends Publisher<?>> in
   public void testCurrentStreamIsTerminatedOnConnectionClose() {
     RSocketClient rSocket = rule.socket;
 
-    Mono.delay(Duration.ofSeconds(1))
-        .doOnNext(v -> rule.connection.dispose())
-        .subscribe();
+    Mono.delay(Duration.ofSeconds(1)).doOnNext(v -> rule.connection.dispose()).subscribe();
 
     StepVerifier.create(interaction.apply(rSocket))
         .expectError(ClosedChannelException.class)