Remove extra code

Signed-off-by: Sergei Ustimenko <[email protected]>

Author: fdesu

plugins/transport-reactor-netty4/src/main/java/org/opensearch/http/reactor/netty4/ReactorNetty4BaseHttpChannel.java

@@ -19,8 +19,7 @@
 import reactor.netty.http.server.HttpServerRequest;
 
 final class ReactorNetty4BaseHttpChannel {
-    static final String CHANNEL_PROPERTY = "channel";
-
+    private static final String CHANNEL_PROPERTY = "channel";
     private static final String SSL_HANDLER_PROPERTY = "ssl_http";
     private static final String SSL_ENGINE_PROPERTY = "ssl_engine";
 

plugins/transport-reactor-netty4/src/main/java/org/opensearch/transport/reactor/netty4/Netty4Utils.java

@@ -12,7 +12,6 @@
 import org.opensearch.ExceptionsHelper;
 import org.opensearch.common.Booleans;
 import org.opensearch.common.concurrent.CompletableContext;
-import org.opensearch.core.action.ActionListener;
 import org.opensearch.core.common.bytes.BytesArray;
 import org.opensearch.core.common.bytes.BytesReference;
 
@@ -26,9 +25,7 @@
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.CompositeByteBuf;
 import io.netty.buffer.Unpooled;
-import io.netty.channel.Channel;
 import io.netty.channel.ChannelFuture;
-import io.netty.channel.ChannelPromise;
 import io.netty.util.NettyRuntime;
 
 /**
@@ -142,29 +139,4 @@ public static void addListener(ChannelFuture channelFuture, CompletableContext<V
             }
         });
     }
-
-    /**
-     * Creates a {@link ChannelPromise} for the given {@link Channel} and adds a listener that invokes the given {@link ActionListener}
-     * on its completion.
-     * @param listener lister to invoke
-     * @param channel channel
-     * @return write promise
-     */
-    public static ChannelPromise addPromise(ActionListener<Void> listener, Channel channel) {
-        ChannelPromise writePromise = channel.newPromise();
-        writePromise.addListener(f -> {
-            if (f.isSuccess()) {
-                listener.onResponse(null);
-            } else {
-                final Throwable cause = f.cause();
-                ExceptionsHelper.maybeDieOnAnotherThread(cause);
-                if (cause instanceof Error) {
-                    listener.onFailure(new Exception(cause));
-                } else {
-                    listener.onFailure((Exception) cause);
-                }
-            }
-        });
-        return writePromise;
-    }
 }