public class ReactorNettyWebSocketClient extends WebSocketClientSupport implements WebSocketClient
WebSocketClient
implementation for use with Reactor Netty.Modifier and Type | Field and Description |
---|---|
private HttpClient |
httpClient |
logger
Constructor and Description |
---|
ReactorNettyWebSocketClient()
Default constructor.
|
ReactorNettyWebSocketClient(java.util.function.Consumer<? super HttpClientOptions.Builder> clientOptions)
Constructor that accepts an
HttpClientOptions.Builder consumer
to supply to HttpClient#create(Consumer) . |
Modifier and Type | Method and Description |
---|---|
<any> |
execute(java.net.URI url,
HttpHeaders headers,
WebSocketHandler handler)
A variant of
WebSocketClient.execute(URI, WebSocketHandler) with custom headers. |
<any> |
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.
|
HttpClient |
getHttpClient()
Return the configured
HttpClient . |
private void |
setNettyHeaders(HttpHeaders headers,
io.netty.handler.codec.http.HttpHeaders nettyHeaders) |
private HttpHeaders |
toHttpHeaders(HttpClientResponse response) |
afterHandshake, beforeHandshake
public ReactorNettyWebSocketClient()
public ReactorNettyWebSocketClient(java.util.function.Consumer<? super HttpClientOptions.Builder> clientOptions)
HttpClientOptions.Builder
consumer
to supply to HttpClient#create(Consumer)
.public HttpClient getHttpClient()
HttpClient
.public <any> execute(java.net.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 <any> execute(java.net.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.private void setNettyHeaders(HttpHeaders headers, io.netty.handler.codec.http.HttpHeaders nettyHeaders)
private HttpHeaders toHttpHeaders(HttpClientResponse response)