diff --git a/pom.xml b/pom.xml
index 07a521b..328b303 100644
--- a/pom.xml
+++ b/pom.xml
@@ -33,29 +33,8 @@
   </scm>
 
   <properties>
-    <reactor.version>2020.0.32</reactor.version>
-
     <distributionManagement.url>https://maven.pkg.github.com/scalecube/scalecube-commons
     </distributionManagement.url>
   </properties>
 
-  <dependencyManagement>
-    <dependencies>
-      <dependency>
-        <groupId>io.projectreactor</groupId>
-        <artifactId>reactor-bom</artifactId>
-        <version>${reactor.version}</version>
-        <type>pom</type>
-        <scope>import</scope>
-      </dependency>
-    </dependencies>
-  </dependencyManagement>
-
-  <dependencies>
-    <dependency>
-      <groupId>io.projectreactor</groupId>
-      <artifactId>reactor-core</artifactId>
-    </dependency>
-  </dependencies>
-
 </project>
diff --git a/src/main/java/io/scalecube/net/Address.java b/src/main/java/io/scalecube/net/Address.java
index 2555f0b..050b0dc 100644
--- a/src/main/java/io/scalecube/net/Address.java
+++ b/src/main/java/io/scalecube/net/Address.java
@@ -134,7 +134,7 @@ public Address port(int port) {
    * @param portOffset portOffset
    * @return address instance
    */
-  public Address addPortOffset(int portOffset) {
+  public Address withPortOffset(int portOffset) {
     return Address.create(host, port + portOffset);
   }
 
diff --git a/src/main/java/io/scalecube/reactor/RetryNonSerializedEmitFailureHandler.java b/src/main/java/io/scalecube/reactor/RetryNonSerializedEmitFailureHandler.java
deleted file mode 100644
index 33c1044..0000000
--- a/src/main/java/io/scalecube/reactor/RetryNonSerializedEmitFailureHandler.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package io.scalecube.reactor;
-
-import reactor.core.publisher.SignalType;
-import reactor.core.publisher.Sinks.EmitFailureHandler;
-import reactor.core.publisher.Sinks.EmitResult;
-
-public class RetryNonSerializedEmitFailureHandler implements EmitFailureHandler {
-
-  public static final RetryNonSerializedEmitFailureHandler RETRY_NON_SERIALIZED =
-      new RetryNonSerializedEmitFailureHandler();
-
-  @Override
-  public boolean onEmitFailure(SignalType signalType, EmitResult emitResult) {
-    return emitResult == EmitResult.FAIL_NON_SERIALIZED;
-  }
-}