Class TcpEventBusBridge
- java.lang.Object
-
- io.vertx.rxjava3.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 Completableclose()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()Single<TcpEventBusBridge>listen()Start listening on the port and host as configured in theNetServerOptionsused when creating the server.Single<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.Single<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.Single<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 Single<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 Single<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 Single<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 Single<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
-
close
public Completable close()
Close the current socket.- 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)
-
-