jetty.project
jetty.project copied to clipboard
Jetty 12 - Add a WebSocket MessageSink for Flow.Publisher
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.
}
}
This issue has been automatically marked as stale because it has been a full year without activity. It will be closed if no further activity occurs. Thank you for your contributions.