Class TcpEventBusBridge
- java.lang.Object
-
- io.vertx.reactivex.ext.eventbus.bridge.tcp.TcpEventBusBridge
-
-
Field Summary
Fields Modifier and Type Field Description static io.vertx.lang.rx.TypeArg<TcpEventBusBridge>__TYPE_ARG
-
Constructor Summary
Constructors Constructor Description TcpEventBusBridge(TcpEventBusBridge delegate)TcpEventBusBridge(Object delegate)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Future<Void>close()Close the current socket.static TcpEventBusBridgecreate(Vertx vertx)static TcpEventBusBridgecreate(Vertx vertx, BridgeOptions options)static TcpEventBusBridgecreate(Vertx vertx, BridgeOptions options, NetServerOptions netServerOptions)static TcpEventBusBridgecreate(Vertx vertx, BridgeOptions options, NetServerOptions netServerOptions, Handler<BridgeEvent> eventHandler)booleanequals(Object o)TcpEventBusBridgegetDelegate()inthashCode()Future<TcpEventBusBridge>listen()Start listening on the port and host as configured in theNetServerOptionsused when creating the server.Future<TcpEventBusBridge>listen(int port)Start listening on the specified port and host "0.0.0.0", ignoring port and host configured in theNetServerOptionsused when creating the server.Future<TcpEventBusBridge>listen(int port, String address)Start listening on the specified port and host, ignoring port and host configured in theNetServerOptionsused when creating the server.Future<TcpEventBusBridge>listen(SocketAddress localAddress)Start listening on the specified local address, ignoring port and host configured in the used when creating the server.static TcpEventBusBridgenewInstance(TcpEventBusBridge arg)CompletablerxClose()Close the current socket.Single<TcpEventBusBridge>rxListen()Start listening on the port and host as configured in theNetServerOptionsused when creating the server.Single<TcpEventBusBridge>rxListen(int port)Start listening on the specified port and host "0.0.0.0", ignoring port and host configured in theNetServerOptionsused when creating the server.Single<TcpEventBusBridge>rxListen(int port, String address)Start listening on the specified port and host, ignoring port and host configured in theNetServerOptionsused when creating the server.Single<TcpEventBusBridge>rxListen(SocketAddress localAddress)Start listening on the specified local address, ignoring port and host configured in the used when creating the server.StringtoString()
-
-
-
Field Detail
-
__TYPE_ARG
public static final io.vertx.lang.rx.TypeArg<TcpEventBusBridge> __TYPE_ARG
-
-
Constructor Detail
-
TcpEventBusBridge
public TcpEventBusBridge(TcpEventBusBridge delegate)
-
TcpEventBusBridge
public TcpEventBusBridge(Object delegate)
-
-
Method Detail
-
getDelegate
public TcpEventBusBridge getDelegate()
- Specified by:
getDelegatein interfaceio.vertx.lang.rx.RxDelegate
-
create
public static TcpEventBusBridge create(Vertx vertx)
-
create
public static TcpEventBusBridge create(Vertx vertx, BridgeOptions options)
-
create
public static TcpEventBusBridge create(Vertx vertx, BridgeOptions options, NetServerOptions netServerOptions)
-
create
public static TcpEventBusBridge create(Vertx vertx, BridgeOptions options, NetServerOptions netServerOptions, Handler<BridgeEvent> eventHandler)
-
listen
public Future<TcpEventBusBridge> listen()
Start listening on the port and host as configured in theNetServerOptionsused when creating the server.- Returns:
- a future of the result
-
rxListen
public Single<TcpEventBusBridge> rxListen()
Start listening on the port and host as configured in theNetServerOptionsused when creating the server.- Returns:
- a future of the result
-
listen
public Future<TcpEventBusBridge> listen(int port, String address)
Start listening on the specified port and host, ignoring port and host configured in theNetServerOptionsused when creating the server.- Parameters:
port- the tcp portaddress- the local address- Returns:
- a future of the result
-
rxListen
public Single<TcpEventBusBridge> rxListen(int port, String address)
Start listening on the specified port and host, ignoring port and host configured in theNetServerOptionsused when creating the server.- Parameters:
port- the tcp portaddress- the local address- Returns:
- a future of the result
-
listen
public Future<TcpEventBusBridge> listen(int port)
Start listening on the specified port and host "0.0.0.0", ignoring port and host configured in theNetServerOptionsused when creating the server.- Parameters:
port- the TCP port- Returns:
- a future of the result
-
rxListen
public Single<TcpEventBusBridge> rxListen(int port)
Start listening on the specified port and host "0.0.0.0", ignoring port and host configured in theNetServerOptionsused when creating the server.- Parameters:
port- the TCP port- Returns:
- a future of the result
-
listen
public Future<TcpEventBusBridge> listen(SocketAddress localAddress)
Start listening on the specified local address, ignoring port and host configured in the used when creating the server.- Parameters:
localAddress- the local address to listen on- Returns:
- a future of the result
-
rxListen
public Single<TcpEventBusBridge> rxListen(SocketAddress localAddress)
Start listening on the specified local address, ignoring port and host configured in the used when creating the server.- Parameters:
localAddress- the local address to listen on- Returns:
- a future of the result
-
rxClose
public Completable rxClose()
Close the current socket.- Returns:
- a future of the result
-
newInstance
public static TcpEventBusBridge newInstance(TcpEventBusBridge arg)
-
-