Skip to content

Commit e75d0db

Browse files
committed
updated TcpReactiveSocketFactory to use ReactiveSocketFactory class
1 parent a8c13bd commit e75d0db

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

reactivesocket-netty/src/main/java/io/reactivesocket/netty/tcp/client/TcpReactiveSocketFactory.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020
import io.reactivesocket.DefaultReactiveSocket;
2121
import io.reactivesocket.ReactiveSocket;
2222
import io.reactivesocket.ReactiveSocketFactory;
23-
import io.reactivesocket.ReactiveSocketSocketAddressFactory;
2423
import io.reactivesocket.rx.Completable;
2524
import org.reactivestreams.Publisher;
2625
import org.reactivestreams.Subscriber;
@@ -36,7 +35,7 @@
3635
/**
3736
* An implementation of {@link ReactiveSocketFactory} that creates Netty WebSocket ReactiveSockets.
3837
*/
39-
public class TcpReactiveSocketFactory implements ReactiveSocketSocketAddressFactory<ReactiveSocket> {
38+
public class TcpReactiveSocketFactory implements ReactiveSocketFactory<SocketAddress, ReactiveSocket> {
4039
private static final Logger logger = LoggerFactory.getLogger(TcpReactiveSocketFactory.class);
4140

4241
private final ConnectionSetupPayload connectionSetupPayload;

0 commit comments

Comments
 (0)