From d28d76cbe0625266ee761295f53be5343322c320 Mon Sep 17 00:00:00 2001 From: Steve Gury Date: Mon, 27 Jun 2016 15:22:40 -0700 Subject: [PATCH] Add an overload of `TcpReactiveSocketServer.create` with SocketAddress. **Problem** It is impossible to specify the network interface to use when starting a server. This can be problematic when we want to design test that run in restricted environment (e.g. CI). **Solution** Create an overload of `TcpReactiveSocketServer.create` that accept a SocketAddress instead of just the port. --- .../transport/tcp/server/TcpReactiveSocketServer.java | 4 ++++ 1 file changed, 4 insertions(+) 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)); }