jetty/jetty.project

Jetty 12 - Add a WebSocket MessageSink for Flow.Publisher

Open

#9,722 创建于 2023年5月2日

在 GitHub 查看
 (3 评论) (0 反应) (0 负责人)Java (3,701 star) (1,913 fork)batch import
EnhancementHelp Wanted

描述

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

贡献者指南

技术栈
java
领域
backend
议题类型
feature
难度面向新贡献者的预计实现难度，1 表示很小改动，5 表示专家级工作。
3
预计时间有经验贡献者完成调查、实现、测试并准备 pull request 的粗略时间范围。
3-5 days
活动状态议题当前的可参与程度：新鲜、活跃、陈旧、阻塞或等待维护者输入。
stale
清晰度议题是否清楚说明期望改动、验收标准和下一步。
clear
前置要求
Java 17+Jetty WebSocket APIReactive Streams (Flow.Publisher)
新手友好度1-100 的估计分数，表示该议题对首次贡献者的友好程度。
40
研究方向
This issue requests adding a WebSocket MessageSink implementation that accepts a Flow.Publisher<ByteBuffer>, similar to the existing MessageSink for InputStream. The challenge is classloading issues preventing direct use of Content.Source. The implementation should be placed in the Jetty WebSocket module (likely under `jetty websocket/websocket core common`). Review the existing `InputStreamMessageSink` as a template. The new class should implement `MessageSink` and handle subscription to the publisher. There are no linked PRs or assignees, so this is open for contribution.