jetty/jetty.project
在 GitHub 查看Jetty 12 - Add a WebSocket MessageSink for Flow.Publisher
Open
#9,722 创建于 2023年5月2日
EnhancementHelp Wanted
仓库指标
- Star
- (3,701 star)
- PR 合并指标
- (平均合并 6天 14小时) (30 天内合并 48 个 PR)
描述
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.
}
}