jetty/jetty.project
Jetty 12 - Add a WebSocket MessageSink for Flow.Publisher
オープン
#9,722 opened on 2023/05/02
EnhancementHelp Wanted
Repository metrics
- Stars
- (3,701 個のスター)
- PR merge metrics
- (PR metrics pending)
説明
Jetty version(s) 12+
Enhancement Description
As we have MessageSink for InputStream, we could have an implementation for Flow.Publisher<ByteBuffer> since we cannot directly have Content.Source due to classloading issues.
@WebSocket
public class WSEndpoint {
@OnWebSocketMessage
public void onMessage(Flow.Publisher<ByteBuffer> publisher) {
// Consume the message asynchronously.
}
}