| Package | Description | 
|---|---|
| io.vertx.rxjava3.core.http | |
| io.vertx.rxjava3.core.net | |
| io.vertx.rxjava3.ext.eventbus.bridge.tcp | 
| Modifier and Type | Method and Description | 
|---|---|
NetSocket | 
HttpClientResponse.netSocket()  | 
| Modifier and Type | Method and Description | 
|---|---|
Single<NetSocket> | 
HttpServerRequest.rxToNetSocket()
Establish a TCP tunnel with the client. 
 | 
Single<NetSocket> | 
HttpServerRequest.toNetSocket()
Establish a TCP tunnel with the client. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
static io.vertx.lang.rx.TypeArg<NetSocket> | 
NetSocket.__TYPE_ARG  | 
| Modifier and Type | Method and Description | 
|---|---|
NetSocket | 
NetSocket.closeHandler(Handler<Void> handler)
Set a handler that will be called when the NetSocket is closed 
 | 
NetSocket | 
NetSocket.drainHandler(Handler<Void> handler)  | 
NetSocket | 
NetSocket.endHandler(Handler<Void> endHandler)
 This handler might be called after the close handler when the socket is paused and there are still
 buffers to deliver. 
 | 
NetSocket | 
NetSocket.exceptionHandler(Handler<Throwable> handler)  | 
NetSocket | 
NetSocket.fetch(long amount)  | 
NetSocket | 
NetSocket.handler(Handler<Buffer> handler)  | 
static NetSocket | 
NetSocket.newInstance(NetSocket arg)  | 
NetSocket | 
NetSocket.pause()  | 
NetSocket | 
NetSocket.resume()  | 
NetSocket | 
NetSocket.setWriteQueueMaxSize(int maxSize)  | 
| Modifier and Type | Method and Description | 
|---|---|
Single<NetSocket> | 
NetClient.connect(int port,
       String host)
Open a connection to a server at the specific  
port and host. | 
Single<NetSocket> | 
NetClient.connect(int port,
       String host,
       String serverName)
Open a connection to a server at the specific  
port and host. | 
Single<NetSocket> | 
NetClient.connect(SocketAddress remoteAddress)
Open a connection to a server at the specific  
remoteAddress. | 
Single<NetSocket> | 
NetClient.connect(SocketAddress remoteAddress,
       String serverName)
Open a connection to a server at the specific  
remoteAddress. | 
ReadStream<NetSocket> | 
NetServer.connectStream()
Return the connect stream for this server. 
 | 
Single<NetSocket> | 
NetClient.rxConnect(int port,
         String host)
Open a connection to a server at the specific  
port and host. | 
Single<NetSocket> | 
NetClient.rxConnect(int port,
         String host,
         String serverName)
Open a connection to a server at the specific  
port and host. | 
Single<NetSocket> | 
NetClient.rxConnect(SocketAddress remoteAddress)
Open a connection to a server at the specific  
remoteAddress. | 
Single<NetSocket> | 
NetClient.rxConnect(SocketAddress remoteAddress,
         String serverName)
Open a connection to a server at the specific  
remoteAddress. | 
| Modifier and Type | Method and Description | 
|---|---|
NetServer | 
NetServer.connectHandler(Handler<NetSocket> handler)
Supply a connect handler for this server. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
NetSocket | 
BridgeEvent.socket()
Get the SockJSSocket instance corresponding to the event 
 | 
Copyright © 2021 Eclipse. All rights reserved.