Class TcpEventBusBridge

java.lang.Object
io.vertx.mutiny.ext.eventbus.bridge.tcp.TcpEventBusBridge
All Implemented Interfaces:
MutinyDelegate

public class TcpEventBusBridge extends Object implements MutinyDelegate
TCP EventBus bridge for Vert.x

NOTE: This class has been automatically generated from the original non Mutiny-ified interface using Vert.x codegen.

  • Field Details

  • Constructor Details

    • TcpEventBusBridge

      public TcpEventBusBridge(io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge delegate)
    • TcpEventBusBridge

      public TcpEventBusBridge(Object delegate)
  • Method Details

    • getDelegate

      public io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge getDelegate()
      Specified by:
      getDelegate in interface MutinyDelegate
      Returns:
      the delegate used by this Mutiny object of generated type
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object
    • create

      public static TcpEventBusBridge create(Vertx vertx)
    • create

      public static TcpEventBusBridge create(Vertx vertx, io.vertx.ext.bridge.BridgeOptions options)
    • 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

      @CheckReturnValue public io.smallrye.mutiny.Uni<TcpEventBusBridge> 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

      public TcpEventBusBridge listenAndAwait()
      Blocking variant of listen().

      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

      public TcpEventBusBridge listenAndForget()
      Variant of listen() 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 from listen() but you don't need to compose it with other operations.

      Returns:
      the instance of TcpEventBusBridge to chain method calls.
    • listen

      @CheckReturnValue public io.smallrye.mutiny.Uni<TcpEventBusBridge> listen(int port, String address)
      Listen on specific port and bind to specific address

      Unlike 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
      address - tcp address to the bind
      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.
    • listenAndAwait

      public TcpEventBusBridge listenAndAwait(int port, String address)
      Blocking variant of listen(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 port
      address - tcp address to the bind
      Returns:
      the TcpEventBusBridge instance produced by the operation.
    • listenAndForget

      public TcpEventBusBridge listenAndForget(int port, String address)
      Variant of listen(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 from listen(int,String) but you don't need to compose it with other operations.

      Parameters:
      port - tcp port
      address - tcp address to the bind
      Returns:
      the instance of TcpEventBusBridge to chain method calls.
    • listen

      @CheckReturnValue public io.smallrye.mutiny.Uni<TcpEventBusBridge> listen(int port)
      Listen on specific port

      Unlike 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

      public TcpEventBusBridge listenAndAwait(int port)
      Blocking variant of listen(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

      public TcpEventBusBridge listenAndForget(int port)
      Variant of listen(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 from listen(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

      @CheckReturnValue public io.smallrye.mutiny.Uni<Void> 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

      public Void closeAndAwait()
      Blocking variant of close().

      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()
      Variant of close() that ignores the result of the operation.

      This method subscribes on the result of close(), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from close() but you don't need to compose it with other operations.

    • newInstance

      public static TcpEventBusBridge newInstance(io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge arg)