jetty/jetty.project
Jetty 12 - Add a WebSocket MessageSink for Flow.Publisher
Aperta
#9722 aperta il 2 mag 2023
EnhancementHelp Wanted
Metriche repository
- Star
- (3701 stelle)
- Metriche merge PR
- (Metriche PR in attesa)
Descrizione
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.
}
}