public interface RxWebSocketClient extends WebSocketClient
WebSocketClient interface for RxJava.WebSocketClient| Modifier and Type | Method and Description |
|---|---|
<T extends AutoCloseable> |
connect(Class<T> clientEndpointType,
Map<String,Object> parameters)
Connect the given client endpoint type.
|
<T extends AutoCloseable> |
connect(Class<T> clientEndpointType,
MutableHttpRequest<?> request)
Connect the given client endpoint type to the URI over WebSocket.
|
default <T extends AutoCloseable> |
connect(Class<T> clientEndpointType,
String uri)
Connect the given client endpoint type to the URI over WebSocket.
|
default <T extends AutoCloseable> |
connect(Class<T> clientEndpointType,
URI uri)
Connect the given client endpoint type to the URI over WebSocket.
|
close<T extends AutoCloseable> io.reactivex.Flowable<T> connect(Class<T> clientEndpointType, MutableHttpRequest<?> request)
WebSocketClientconnect in interface WebSocketClientT - The generic typeclientEndpointType - The endpoint type. Should be a class annotated with ClientWebSocketrequest - The original request to establish the connectionPublisher that emits the ClientWebSocket instancedefault <T extends AutoCloseable> io.reactivex.Flowable<T> connect(Class<T> clientEndpointType, URI uri)
connect in interface WebSocketClientT - The generic typeclientEndpointType - The endpoint type. Should be a class annotated with ClientWebSocketuri - The URI to connect overPublisher that emits the ClientWebSocket instance<T extends AutoCloseable> io.reactivex.Flowable<T> connect(Class<T> clientEndpointType, Map<String,Object> parameters)
WebSocketClient.connect(Class, URI) this method will the value declared within the ClientWebSocket as the URI
and expand the URI with the given parameters.connect in interface WebSocketClientT - The generic typeclientEndpointType - The endpoint type. Should be a class annotated with ClientWebSocketparameters - The URI parameters for the endpointPublisher that emits the ClientWebSocket instancedefault <T extends AutoCloseable> io.reactivex.Flowable<T> connect(Class<T> clientEndpointType, String uri)
WebSocketClientconnect in interface WebSocketClientT - The generic typeclientEndpointType - The endpoint type. Should be a class annotated with ClientWebSocketuri - The URI to connect overPublisher that emits the ClientWebSocket instance