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()
Deprecated.
|
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 © 2024 Eclipse. All rights reserved.