vertx / io.vertx.ext.rxjava.eventbus.bridge.tcp / TcpEventBusBridge

TcpEventBusBridge

open class TcpEventBusBridge

TCP EventBus bridge for Vert.x NOTE: This class has been automatically generated from the io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge non RX-ified interface using Vert.x codegen.

Constructors

<init>

TcpEventBusBridge(delegate: TcpEventBusBridge)

Properties

__TYPE_ARG

static val __TYPE_ARG: TypeArg<TcpEventBusBridge>

Functions

close

open fun close(handler: Handler<AsyncResult<Void>>): Unit
open fun close(): Unit

Close the current socket.

create

open static fun create(vertx: Vertx): TcpEventBusBridge
open static fun create(vertx: Vertx, options: BridgeOptions): TcpEventBusBridge
open static fun create(vertx: Vertx, options: BridgeOptions, netServerOptions: NetServerOptions): TcpEventBusBridge
open static fun create(vertx: Vertx, options: BridgeOptions, netServerOptions: NetServerOptions, eventHandler: Handler<BridgeEvent>): TcpEventBusBridge

equals

open fun equals(other: Any?): Boolean

getDelegate

open fun getDelegate(): TcpEventBusBridge

hashCode

open fun hashCode(): Int

listen

open fun listen(): TcpEventBusBridge

Listen on default port 7000

open fun listen(handler: Handler<AsyncResult<TcpEventBusBridge>>): TcpEventBusBridge

Listen on default port 7000 with a handler to report the state of the socket listen operation.

open fun listen(port: Int, address: String): TcpEventBusBridge
open fun listen(port: Int, address: String, handler: Handler<AsyncResult<TcpEventBusBridge>>): TcpEventBusBridge

Listen on specific port and bind to specific address

open fun listen(port: Int): TcpEventBusBridge
open fun listen(port: Int, handler: Handler<AsyncResult<TcpEventBusBridge>>): TcpEventBusBridge

Listen on specific port

newInstance

open static fun newInstance(arg: TcpEventBusBridge): TcpEventBusBridge

rxClose

open fun rxClose(): Single<Void>

Close the current socket.

rxListen

open fun rxListen(): Single<TcpEventBusBridge>

Listen on default port 7000 with a handler to report the state of the socket listen operation.

open fun rxListen(port: Int, address: String): Single<TcpEventBusBridge>

Listen on specific port and bind to specific address

open fun rxListen(port: Int): Single<TcpEventBusBridge>

Listen on specific port

toString

open fun toString(): String