Merge pull request #277 from scalecube/update/reactor-Dysprosium-RELEASE

Updated reactor version to Dysprosium-RELEASE [DONT MERGE]

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>
@@ -90,14 +90,11 @@
 
       <!-- Jackson -->
       <dependency>
-        <groupId>com.fasterxml.jackson.core</groupId>
-        <artifactId>jackson-core</artifactId>
-        <version>${jackson.version}</version>
-      </dependency>
-      <dependency>
-        <groupId>com.fasterxml.jackson.core</groupId>
-        <artifactId>jackson-databind</artifactId>
+        <groupId>com.fasterxml.jackson</groupId>
+        <artifactId>jackson-bom</artifactId>
         <version>${jackson.version}</version>
+        <type>pom</type>
+        <scope>import</scope>
       </dependency>
 
       <!-- Reactor -->

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) {