Updated reactor version to Dysprosium-RELEASE

Author: artem-v

pom.xml

@@ -25,7 +25,7 @@
     <slf4j.version>1.7.7</slf4j.version>
     <jackson.version>2.10.0.pr1</jackson.version>
     <log4j.version>2.8.2</log4j.version>
-    <reactor.version>Californium-SR8</reactor.version>
+    <reactor.version>Dysprosium-RELEASE</reactor.version>
 
     <mockito-junit-jupiter.version>2.27.0</mockito-junit-jupiter.version>
     <junit-jupiter.version>5.1.1</junit-jupiter.version>

transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/TransportImpl.java

@@ -36,7 +36,6 @@
 import reactor.netty.DisposableServer;
 import reactor.netty.NettyInbound;
 import reactor.netty.NettyOutbound;
-import reactor.netty.NettyPipeline.SendOptions;
 import reactor.netty.channel.BootstrapHandlers;
 import reactor.netty.resources.ConnectionProvider;
 import reactor.netty.resources.LoopResources;
@@ -290,10 +289,7 @@ private Message toMessage(ByteBuf byteBuf) {
 
   private Mono<? extends Void> send0(Connection conn, Message message) {
     // do send
-    return conn.outbound()
-        .options(SendOptions::flushOnEach)
-        .send(Mono.just(message).map(this::toByteBuf))
-        .then();
+    return conn.outbound().send(Mono.just(message).map(this::toByteBuf), bb -> true).then();
   }
 
   private ByteBuf toByteBuf(Message message) {