Skip to content

Commit

Permalink
disabled explicit use of address families inside RemoteConnection
Browse files Browse the repository at this point in the history
  • Loading branch information
Aaronontheweb committed May 21, 2019
1 parent 5641543 commit 5d2f46b
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/core/Akka.Remote.TestKit/RemoteConnection.cs
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ public static Task<IChannel> CreateConnection(Role role, IPEndPoint socketAddres
if (role == Role.Client)
{
var connection = new Bootstrap()
.ChannelFactory(() => new TcpSocketChannel(socketAddress.AddressFamily))
.ChannelFactory(() => new TcpSocketChannel())
.Option(ChannelOption.TcpNodelay, true)
.Group(GetClientWorkerPool(poolSize))
.Handler(new ActionChannelInitializer<TcpSocketChannel>(channel =>
Expand All @@ -112,7 +112,7 @@ public static Task<IChannel> CreateConnection(Role role, IPEndPoint socketAddres
{
var connection = new ServerBootstrap()
.Group(GetServerPool(poolSize))
.ChannelFactory(() => new TcpServerSocketChannel(socketAddress.AddressFamily))
.ChannelFactory(() => new TcpServerSocketChannel())
.ChildOption(ChannelOption.TcpNodelay, true)
.ChildHandler(new ActionChannelInitializer<TcpSocketChannel>(channel =>
{
Expand Down

0 comments on commit 5d2f46b

Please sign in to comment.