public class ReactorNettyWebSocketClient extends java.lang.Object implements WebSocketClient
WebSocketClient
implementation for use with Reactor Netty.Constructor and Description |
---|
ReactorNettyWebSocketClient()
Default constructor.
|
ReactorNettyWebSocketClient(reactor.netty.http.client.HttpClient httpClient)
Constructor that accepts an existing
HttpClient builder. |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<java.lang.Void> |
execute(java.net.URI url,
HttpHeaders requestHeaders,
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.netty.http.client.HttpClient |
getHttpClient()
Return the configured
HttpClient . |
public ReactorNettyWebSocketClient()
public ReactorNettyWebSocketClient(reactor.netty.http.client.HttpClient httpClient)
HttpClient
builder.public reactor.netty.http.client.HttpClient getHttpClient()
HttpClient
.public reactor.core.publisher.Mono<java.lang.Void> 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 reactor.core.publisher.Mono<java.lang.Void> execute(java.net.URI url, HttpHeaders requestHeaders, WebSocketHandler handler)
WebSocketClient
WebSocketClient.execute(URI, WebSocketHandler)
with custom headers.execute
in interface WebSocketClient
url
- the handshake urlrequestHeaders
- custom headers for the handshake requesthandler
- the handler of the WebSocket sessionMono<Void>
to indicate the outcome of the
WebSocket session handling.