|
|
|
@ -137,7 +137,7 @@ public abstract class AbstractListenerWebSocketSession<T> extends AbstractWebSoc |
|
|
|
* Suspend receiving until received message(s) are processed and more demand |
|
|
|
* Suspend receiving until received message(s) are processed and more demand |
|
|
|
* is generated by the downstream Subscriber. |
|
|
|
* is generated by the downstream Subscriber. |
|
|
|
* <p><strong>Note:</strong> if the underlying WebSocket API does not provide |
|
|
|
* <p><strong>Note:</strong> if the underlying WebSocket API does not provide |
|
|
|
* flow control for receiving messages, and this method should be a no-op |
|
|
|
* flow control for receiving messages, this method should be a no-op |
|
|
|
* and {@link #canSuspendReceiving()} should return {@code false}. |
|
|
|
* and {@link #canSuspendReceiving()} should return {@code false}. |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
protected abstract void suspendReceiving(); |
|
|
|
protected abstract void suspendReceiving(); |
|
|
|
@ -146,7 +146,7 @@ public abstract class AbstractListenerWebSocketSession<T> extends AbstractWebSoc |
|
|
|
* Resume receiving new message(s) after demand is generated by the |
|
|
|
* Resume receiving new message(s) after demand is generated by the |
|
|
|
* downstream Subscriber. |
|
|
|
* downstream Subscriber. |
|
|
|
* <p><strong>Note:</strong> if the underlying WebSocket API does not provide |
|
|
|
* <p><strong>Note:</strong> if the underlying WebSocket API does not provide |
|
|
|
* flow control for receiving messages, and this method should be a no-op |
|
|
|
* flow control for receiving messages, this method should be a no-op |
|
|
|
* and {@link #canSuspendReceiving()} should return {@code false}. |
|
|
|
* and {@link #canSuspendReceiving()} should return {@code false}. |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
protected abstract void resumeReceiving(); |
|
|
|
protected abstract void resumeReceiving(); |
|
|
|
|