From da4a73193e19b44b6edd77a2a767d2560fa52631 Mon Sep 17 00:00:00 2001
From: Artem Vysochyn <artem.vysochyn@gmail.com>
Date: Sun, 22 Sep 2024 07:29:02 +0300
Subject: [PATCH 1/2] Removed dependency on reactor, removed
 RetryNonSerializedEmitFailureHandler

---
 pom.xml                                       | 21 -------------------
 .../RetryNonSerializedEmitFailureHandler.java | 16 --------------
 2 files changed, 37 deletions(-)
 delete mode 100644 src/main/java/io/scalecube/reactor/RetryNonSerializedEmitFailureHandler.java

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/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;
-  }
-}

From c46260e215c6b6a60a4e217a2982c492727e5dcc Mon Sep 17 00:00:00 2001
From: Artem Vysochyn <artem.vysochyn@gmail.com>
Date: Sun, 22 Sep 2024 07:31:41 +0300
Subject: [PATCH 2/2] Renamings in Address

---
 src/main/java/io/scalecube/net/Address.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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);
   }