Class StandardWebSocketSession
- java.lang.Object
- org.springframework.web.reactive.socket.adapter.AbstractWebSocketSession<T>
- org.springframework.web.reactive.socket.adapter.AbstractListenerWebSocketSession<Session>
- org.springframework.web.reactive.socket.adapter.StandardWebSocketSession
- All Implemented Interfaces:
org.reactivestreams.Subscriber<Void>,WebSocketSession
- Direct Known Subclasses:
TomcatWebSocketSession
public class StandardWebSocketSession extends AbstractListenerWebSocketSession<Session>
SpringWebSocketSessionadapter for a standard Java (JSR 356)Session.- Since:
- 5.0
- Author:
- Violeta Georgieva, Rossen Stoyanchev
Nested Class Summary
Nested classes/interfaces inherited from class org.springframework.web.reactive.socket.adapter.AbstractListenerWebSocketSession
AbstractListenerWebSocketSession.WebSocketSendProcessor
Field Summary
Fields inherited from class org.springframework.web.reactive.socket.adapter.AbstractWebSocketSession
logger
Constructor Summary
Constructors Constructor Description StandardWebSocketSession(Session session, HandshakeInfo info, DataBufferFactory factory)StandardWebSocketSession(Session session, HandshakeInfo info, DataBufferFactory factory, reactor.core.publisher.MonoProcessor<Void> completionMono)
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected booleancanSuspendReceiving()Whether the underlying WebSocket API has flow control and can suspend and resume the receiving of messages.reactor.core.publisher.Mono<Void>close(CloseStatus status)Close the WebSocket session with the given status.protected voidresumeReceiving()Resume receiving new message(s) after demand is generated by the downstream Subscriber.protected booleansendMessage(WebSocketMessage message)Send the given WebSocket message.protected voidsuspendReceiving()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.AbstractListenerWebSocketSession
getSendProcessor, onComplete, onError, onNext, onSubscribe, receive, send
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
Methods inherited from interface org.springframework.web.reactive.socket.WebSocketSession
close
Constructor Detail
StandardWebSocketSession
public StandardWebSocketSession(Session session, HandshakeInfo info, DataBufferFactory factory)
StandardWebSocketSession
public StandardWebSocketSession(Session session, HandshakeInfo info, DataBufferFactory factory, @Nullable reactor.core.publisher.MonoProcessor<Void> completionMono)
Method Detail
canSuspendReceiving
protected boolean canSuspendReceiving()
Description copied from class:AbstractListenerWebSocketSessionWhether the underlying WebSocket API has flow control and can suspend and resume the receiving of messages.Note: Sub-classes are encouraged to start out in suspended mode, if possible, and wait until demand is received.
- Specified by:
canSuspendReceivingin classAbstractListenerWebSocketSession<Session>
suspendReceiving
protected void suspendReceiving()
Description copied from class:AbstractListenerWebSocketSessionSuspend receiving until received message(s) are processed and more demand is generated by the downstream Subscriber.Note: if the underlying WebSocket API does not provide flow control for receiving messages, this method should be a no-op and
AbstractListenerWebSocketSession.canSuspendReceiving()should returnfalse.- Specified by:
suspendReceivingin classAbstractListenerWebSocketSession<Session>
resumeReceiving
protected void resumeReceiving()
Description copied from class:AbstractListenerWebSocketSessionResume receiving new message(s) after demand is generated by the downstream Subscriber.Note: if the underlying WebSocket API does not provide flow control for receiving messages, this method should be a no-op and
AbstractListenerWebSocketSession.canSuspendReceiving()should returnfalse.- Specified by:
resumeReceivingin classAbstractListenerWebSocketSession<Session>
sendMessage
protected boolean sendMessage(WebSocketMessage message) throws IOException
Description copied from class:AbstractListenerWebSocketSessionSend the given WebSocket message.Note: Sub-classes are responsible for releasing the payload data buffer, once fully written, if pooled buffers apply to the underlying container.
- Specified by:
sendMessagein classAbstractListenerWebSocketSession<Session>- Throws:
IOException
close
public reactor.core.publisher.Mono<Void> close(CloseStatus status)
Description copied from interface:WebSocketSessionClose the WebSocket session with the given status.- Parameters:
status- the close status