public class ReactorNettyWebSocketClient extends WebSocketClientSupport implements WebSocketClient
WebSocketClient implementation for use with Reactor Netty.logger| Constructor and Description |
|---|
ReactorNettyWebSocketClient()
Default constructor.
|
ReactorNettyWebSocketClient(java.util.function.Consumer<? super reactor.ipc.netty.http.client.HttpClientOptions.Builder> clientOptions)
Constructor that accepts an
HttpClientOptions.Builder consumer
to supply to HttpClient.create(Consumer). |
| Modifier and Type | Method and Description |
|---|---|
reactor.core.publisher.Mono<java.lang.Void> |
execute(java.net.URI url,
HttpHeaders headers,
WebSocketHandler handler)
A variant of
WebSocketClient.execute(URI, WebSocketHandler) with custom headers. |
reactor.core.publisher.Mono<java.lang.Void> |
execute(java.net.URI url,
WebSocketHandler handler)
Execute a handshake request to the given url and handle the resulting
WebSocket session with the given handler.
|
reactor.ipc.netty.http.client.HttpClient |
getHttpClient()
Return the configured
HttpClient. |
afterHandshake, beforeHandshakepublic ReactorNettyWebSocketClient()
public ReactorNettyWebSocketClient(java.util.function.Consumer<? super reactor.ipc.netty.http.client.HttpClientOptions.Builder> clientOptions)
HttpClientOptions.Builder consumer
to supply to HttpClient.create(Consumer).public reactor.ipc.netty.http.client.HttpClient getHttpClient()
HttpClient.public reactor.core.publisher.Mono<java.lang.Void> execute(java.net.URI url,
WebSocketHandler handler)
WebSocketClientexecute in interface WebSocketClienturl - the handshake urlhandler - the handler of the WebSocket sessionMono<Void> to indicate the outcome of the
WebSocket session handling.public reactor.core.publisher.Mono<java.lang.Void> execute(java.net.URI url,
HttpHeaders headers,
WebSocketHandler handler)
WebSocketClientWebSocketClient.execute(URI, WebSocketHandler) with custom headers.execute in interface WebSocketClienturl - the handshake urlheaders - custom headers for the handshake requesthandler - the handler of the WebSocket sessionMono<Void> to indicate the outcome of the
WebSocket session handling.