 |
-
-
Method Summary
All Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
protected boolean |
canSuspendReceiving()
Whether the underlying WebSocket API has flow control and can suspend and
resume the receiving of messages.
|
reactor.core.publisher.Mono<java.lang.Void> |
close(CloseStatus status)
Close the WebSocket session with the given status.
|
protected void |
resumeReceiving()
Resume receiving new message(s) after demand is generated by the
downstream Subscriber.
|
protected boolean |
sendMessage(WebSocketMessage message)
Send the given WebSocket message.
|
protected void |
suspendReceiving()
Suspend receiving until received message(s) are processed and more demand
is generated by the downstream Subscriber.
|
-
Methods inherited from class org.springframework.web.reactive.socket.adapter.AbstractWebSocketSession
binaryMessage, bufferFactory, getAttributes, getDelegate, getHandshakeInfo, getId, getLogPrefix, pingMessage, pongMessage, textMessage, toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
Constructor Detail
-
JettyWebSocketSession
public JettyWebSocketSession(org.eclipse.jetty.websocket.api.Session session,
HandshakeInfo info,
DataBufferFactory factory,
@Nullable
reactor.core.publisher.MonoProcessor<java.lang.Void> completionMono)
|
|