- 18 12月, 2016 2 次提交
-
-
由 Rossen Stoyanchev 提交于
Move WebSocketMessage factory methods to the WebSocketSession which has the bufferFactory() needed to create message payloads. WebSocketMessage is left with one public constructor. WebSocketMessage exposes convenience retain/releasePayload methods.
-
由 Rossen Stoyanchev 提交于
Expose bufferFactory() at the WebSocketSession level for creating payloads like ReactiveHttpOutputMessage does. Promote getId(), getUri(), and bufferFactory() to the base class WebSocketSessionSupport.
-
- 13 12月, 2016 8 次提交
-
-
由 Rossen Stoyanchev 提交于
The WebSocketHandler adapters for all runtimes now extend WebSocketHandlerAdapterSupport, which now also exposes a shared DataBufferFactory property initialized from the response. Issue: SPR-14527
-
由 Rossen Stoyanchev 提交于
-
由 Rossen Stoyanchev 提交于
-
由 Rossen Stoyanchev 提交于
suspend/resumeReceiving in the AbstractListenerWebSocketSession are now abstract methods. In Tomcat/Jetty these methods are no-op implementations that are then coupled with a buffering strategy via Flux#onBackpressureBuffer. In Undertow they rely on flow control for receiving WebSocket messages. Issue: SPR-14527
-
由 Violeta Georgieva 提交于
- Added suspended flag to indicate whether the ReceivePublisher is able to process the incoming messages. - Use buffer strategy for the incoming messages. Issue: SPR-14527
-
由 Rossen Stoyanchev 提交于
Dropped "Support" from the name since it not only provides support methods but actually implements WebSocketSession. Renamed inner classes: WebSocketMessagePublisher -> WebSocketReceivePublisher WebSocketMessageProcessor -> WebSocketSendProcessor Add protected getter for sendProcessor. Reduce scoping: WebSocketReceivePublisher -> private WebSocketSendProcessor -> protected WebSocketSendProcessor#setReady -> public (class is still protected) A few more method name alignments and Javadoc updates. Issue: SPR-14527
-
由 Violeta Georgieva 提交于
Issue: SPR-14527
-
由 Violeta Georgieva 提交于
Issue: SPR-14527
-