| Package | Description | 
|---|---|
| io.vertx.rxjava.core.http | |
| io.vertx.rxjava.core.net | |
| io.vertx.rxjava.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. | 
| Modifier and Type | Method and Description | 
|---|---|
| void | HttpServerRequest. toNetSocket(Handler<AsyncResult<NetSocket>> handler)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. sendFile(String filename)Same as  sendFile(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)but also takes a handler that will be called when the send has completed or
 a failure has occurred | 
| NetSocket | NetSocket. sendFile(String filename,
        Handler<AsyncResult<Void>> resultHandler)Same as  sendFile(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)but also takes a handler that will be called when the send has completed or
 a failure has occurred | 
| NetSocket | NetSocket. sendFile(String filename,
        long offset)Same as  sendFile(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)but also takes a handler that will be called when the send has completed or
 a failure has occurred | 
| NetSocket | NetSocket. sendFile(String filename,
        long offset,
        Handler<AsyncResult<Void>> resultHandler)Same as  sendFile(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)but also takes a handler that will be called when the send has completed or
 a failure has occurred | 
| NetSocket | NetSocket. sendFile(String filename,
        long offset,
        long length)Same as  sendFile(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)but also takes a handler that will be called when the send has completed or
 a failure has occurred | 
| NetSocket | NetSocket. sendFile(String filename,
        long offset,
        long length,
        Handler<AsyncResult<Void>> resultHandler)Same as  sendFile(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)but also takes a handler that will be called when the send has completed or
 a failure has occurred | 
| NetSocket | NetSocket. setWriteQueueMaxSize(int maxSize) | 
| NetSocket | NetSocket. upgradeToSsl()Upgrade channel to use SSL/TLS. | 
| NetSocket | NetSocket. upgradeToSsl(Handler<AsyncResult<Void>> handler)Upgrade channel to use SSL/TLS. | 
| NetSocket | NetSocket. upgradeToSsl(String serverName)Upgrade channel to use SSL/TLS. | 
| NetSocket | NetSocket. upgradeToSsl(String serverName,
            Handler<AsyncResult<Void>> handler)Upgrade channel to use SSL/TLS. | 
| Modifier and Type | Method and Description | 
|---|---|
| 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  portandhost. | 
| Single<NetSocket> | NetClient. rxConnect(int port,
         String host,
         String serverName)Open a connection to a server at the specific  portandhost. | 
| 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 | 
|---|---|
| NetClient | NetClient. connect(int port,
       String host,
       Handler<AsyncResult<NetSocket>> connectHandler)Open a connection to a server at the specific  portandhost. | 
| NetClient | NetClient. connect(int port,
       String host,
       String serverName,
       Handler<AsyncResult<NetSocket>> connectHandler)Open a connection to a server at the specific  portandhost. | 
| NetClient | NetClient. connect(SocketAddress remoteAddress,
       Handler<AsyncResult<NetSocket>> connectHandler)Open a connection to a server at the specific  remoteAddress. | 
| NetClient | NetClient. connect(SocketAddress remoteAddress,
       String serverName,
       Handler<AsyncResult<NetSocket>> connectHandler)Open a connection to a server at the specific  remoteAddress. | 
| 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 © 2020 Eclipse. All rights reserved.