jetty/jetty.project
GitHub で見るJetty 12 - Add a WebSocket MessageSink for Flow.Publisher
Open
#9,722 opened on 2023年5月2日
EnhancementHelp Wanted
Repository metrics
- Stars
- (3,701 stars)
- PR merge metrics
- (平均マージ 6d 14h) (30d で 48 merged PRs)
説明
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.
}
}