Class TcpEventBusBridge
- All Implemented Interfaces:
MutinyDelegate
original
non Mutiny-ified interface using Vert.x codegen.-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionTcpEventBusBridge
(io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge delegate) TcpEventBusBridge
(Object delegate) -
Method Summary
Modifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<Void>
close()
Close the current socket.Blocking variant ofclose()
.void
Variant ofclose()
that ignores the result of the operation.static TcpEventBusBridge
static TcpEventBusBridge
static TcpEventBusBridge
create
(Vertx vertx, io.vertx.ext.bridge.BridgeOptions options, io.vertx.core.net.NetServerOptions netServerOptions) static TcpEventBusBridge
create
(Vertx vertx, io.vertx.ext.bridge.BridgeOptions options, io.vertx.core.net.NetServerOptions netServerOptions, Consumer<BridgeEvent> eventHandler) boolean
io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge
int
hashCode()
io.smallrye.mutiny.Uni<TcpEventBusBridge>
listen()
Listen on default port 7000 with a handler to report the state of the socket listen operation.io.smallrye.mutiny.Uni<TcpEventBusBridge>
listen
(int port) Listen on specific portio.smallrye.mutiny.Uni<TcpEventBusBridge>
Listen on specific port and bind to specific addressBlocking variant oflisten()
.listenAndAwait
(int port) Blocking variant oflisten(int)
.listenAndAwait
(int port, String address) Blocking variant oflisten(int,String)
.Variant oflisten()
that ignores the result of the operation.listenAndForget
(int port) Variant oflisten(int)
that ignores the result of the operation.listenAndForget
(int port, String address) Variant oflisten(int,String)
that ignores the result of the operation.static TcpEventBusBridge
newInstance
(io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge arg) toString()
-
Field Details
-
__TYPE_ARG
-
-
Constructor Details
-
TcpEventBusBridge
public TcpEventBusBridge(io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge delegate) -
TcpEventBusBridge
-
-
Method Details
-
getDelegate
public io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge getDelegate()- Specified by:
getDelegate
in interfaceMutinyDelegate
- Returns:
- the delegate used by this Mutiny object of generated type
-
toString
-
equals
-
hashCode
public int hashCode() -
create
-
create
-
create
public static TcpEventBusBridge create(Vertx vertx, io.vertx.ext.bridge.BridgeOptions options, io.vertx.core.net.NetServerOptions netServerOptions) -
create
public static TcpEventBusBridge create(Vertx vertx, io.vertx.ext.bridge.BridgeOptions options, io.vertx.core.net.NetServerOptions netServerOptions, Consumer<BridgeEvent> eventHandler) -
listen
Listen on default port 7000 with a handler to report the state of the socket listen operation.Unlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
listenAndAwait
Blocking variant oflisten()
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Returns:
- the TcpEventBusBridge instance produced by the operation.
-
listenAndForget
Variant oflisten()
that ignores the result of the operation.This method subscribes on the result of
listen()
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromlisten()
but you don't need to compose it with other operations.- Returns:
- the instance of TcpEventBusBridge to chain method calls.
-
listen
Listen on specific port and bind to specific addressUnlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Parameters:
port
- tcp portaddress
- tcp address to the bind- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
listenAndAwait
Blocking variant oflisten(int,String)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Parameters:
port
- tcp portaddress
- tcp address to the bind- Returns:
- the TcpEventBusBridge instance produced by the operation.
-
listenAndForget
Variant oflisten(int,String)
that ignores the result of the operation.This method subscribes on the result of
listen(int,String)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromlisten(int,String)
but you don't need to compose it with other operations.- Parameters:
port
- tcp portaddress
- tcp address to the bind- Returns:
- the instance of TcpEventBusBridge to chain method calls.
-
listen
Listen on specific portUnlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Parameters:
port
- tcp port- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
listenAndAwait
Blocking variant oflisten(int)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Parameters:
port
- tcp port- Returns:
- the TcpEventBusBridge instance produced by the operation.
-
listenAndForget
Variant oflisten(int)
that ignores the result of the operation.This method subscribes on the result of
listen(int)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromlisten(int)
but you don't need to compose it with other operations.- Parameters:
port
- tcp port- Returns:
- the instance of TcpEventBusBridge to chain method calls.
-
close
Close the current socket.Unlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
closeAndAwait
Blocking variant ofclose()
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Returns:
- the Void instance produced by the operation.
-
closeAndForget
public void closeAndForget() -
newInstance
-