jetty/jetty.project

Jetty 12 - Add a WebSocket MessageSink for Flow.Publisher

開放

#9,722 建立於 2023年5月2日

 (3 則留言) (0 個反應) (0 位負責人)Java (1,913 個分叉)batch import
EnhancementHelp Wanted

倉庫指標

星標
 (3,701 顆星)
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.
  }
}

貢獻者指南