public class ReactorNettyWebSocketClient extends WebSocketClientSupport implements WebSocketClient
WebSocketClient
implementation for use with Reactor Netty.logger
Constructor and Description |
---|
ReactorNettyWebSocketClient()
Default constructor.
|
ReactorNettyWebSocketClient(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<Void> |
execute(URI url,
HttpHeaders headers,
WebSocketHandler handler)
A variant of
WebSocketClient.execute(URI, WebSocketHandler) with custom headers. |
reactor.core.publisher.Mono<Void> |
execute(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, beforeHandshake
public ReactorNettyWebSocketClient()
public ReactorNettyWebSocketClient(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<Void> execute(URI url, WebSocketHandler handler)
WebSocketClient
execute
in interface WebSocketClient
url
- the handshake urlhandler
- the handler of the WebSocket sessionMono<Void>
to indicate the outcome of the
WebSocket session handling.public reactor.core.publisher.Mono<Void> execute(URI url, HttpHeaders headers, WebSocketHandler handler)
WebSocketClient
WebSocketClient.execute(URI, WebSocketHandler)
with custom headers.execute
in interface WebSocketClient
url
- 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.