diff --git a/reactivesocket-transport-tcp/src/main/java/io/reactivesocket/transport/tcp/server/TcpReactiveSocketServer.java b/reactivesocket-transport-tcp/src/main/java/io/reactivesocket/transport/tcp/server/TcpReactiveSocketServer.java index 5cffca631..ac734fd41 100644 --- a/reactivesocket-transport-tcp/src/main/java/io/reactivesocket/transport/tcp/server/TcpReactiveSocketServer.java +++ b/reactivesocket-transport-tcp/src/main/java/io/reactivesocket/transport/tcp/server/TcpReactiveSocketServer.java @@ -95,6 +95,10 @@ public static TcpReactiveSocketServer create(int port) { return create(TcpServer.newServer(port)); } + public static TcpReactiveSocketServer create(SocketAddress address) { + return create(TcpServer.newServer(address)); + } + public static TcpReactiveSocketServer create(TcpServer rxNettyServer) { return new TcpReactiveSocketServer(configure(rxNettyServer)); }