jetty.project icon indicating copy to clipboard operation
jetty.project copied to clipboard

Jetty 12 - Add a WebSocket MessageSink for Flow.Publisher

Open sbordet opened this issue 2 years ago • 2 comments

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.
  }
}

sbordet avatar May 02 '23 08:05 sbordet

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.

github-actions[bot] avatar May 02 '24 00:05 github-actions[bot]