Use session. to compose on
the inbound message stream, and session. to provide the outbound message stream.
| Modifier and Type | Method and Description |
|---|---|
| public WebSocketMessage | binaryMessage(Function<DataBufferFactory, DataBuffer> payloadFactory)
Factory method to create a binary WebSocketMessage using the
|
| public DataBufferFactory | Returns: the buffer factory for the sessionReturn a |
| public default Mono | |
| public Mono | |
| public Mono | closeStatus()
Provides access to the |
| public Map | Returns: a Map with the session attributes (nevernull)Return the map with attributes associated with the WebSocket session. |
| public HandshakeInfo | |
| public String | |
| public boolean | |
| public WebSocketMessage | pingMessage(Function<DataBufferFactory, DataBuffer> payloadFactory)
Factory method to create a ping WebSocketMessage using the
|
| public WebSocketMessage | pongMessage(Function<DataBufferFactory, DataBuffer> payloadFactory)
Factory method to create a pong WebSocketMessage using the
|
| public Flux | |
| public Mono | send(Publisher<WebSocketMessage> messages)
Give a source of outgoing messages, write the messages and return a
|
| public WebSocketMessage | textMessage(String payload)
Factory method to create a text |
| binaryMessage | back to summary |
|---|---|
| public WebSocketMessage binaryMessage(Function<DataBufferFactory, DataBuffer> payloadFactory) Factory method to create a binary WebSocketMessage using the
| |
| bufferFactory | back to summary |
|---|---|
| public DataBufferFactory bufferFactory() Return a
| |
| close | back to summary |
|---|---|
| public default Mono Close the WebSocket session with | |
| close | back to summary |
|---|---|
| public Mono Close the WebSocket session with the given status.
| |
| closeStatus | back to summary |
|---|---|
| public Mono Provides access to the
| |
| getAttributes | back to summary |
|---|---|
| public Map Return the map with attributes associated with the WebSocket session. | |
| getHandshakeInfo | back to summary |
|---|---|
| public HandshakeInfo getHandshakeInfo() Return information from the handshake request. | |
| getId | back to summary |
|---|---|
| public String getId() Return the id for the session. | |
| isOpen | back to summary |
|---|---|
| public boolean isOpen() Whether the underlying connection is open.
| |
| pingMessage | back to summary |
|---|---|
| public WebSocketMessage pingMessage(Function<DataBufferFactory, DataBuffer> payloadFactory) Factory method to create a ping WebSocketMessage using the
| |
| pongMessage | back to summary |
|---|---|
| public WebSocketMessage pongMessage(Function<DataBufferFactory, DataBuffer> payloadFactory) Factory method to create a pong WebSocketMessage using the
| |
| receive | back to summary |
|---|---|
| public Flux Provides access to the stream of inbound messages. This stream receives a completion or error signal when the connection
is closed. In a typical See the class-level doc of | |
| send | back to summary |
|---|---|
| public Mono Give a source of outgoing messages, write the messages and return a
See the class-level doc of | |
| textMessage | back to summary |
|---|---|
| public WebSocketMessage textMessage(String payload) Factory method to create a text | |