jetty / jetty/jetty.project

Jetty 12 - Add a WebSocket MessageSink for Flow.Publisher

Open
#9,722 3 comments 0 reactions 0 assignees View on GitHub
Enhancement Help Wanted
Dominant language
Java
Stars
4.1k
Forks
2k
Avg merge
3d 56m
Merged PRs (30d)
48

Description

**Jetty version(s)**
12+

**Enhancement Description**
As we have `MessageSink` for `InputStream`, we could have an implementation for `Flow.Publisher` since we cannot directly have `Content.Source` due to classloading issues.

```java
@WebSocket
public class WSEndpoint {
@OnWebSocketMessage
public void onMessage(Flow.Publisher publisher) {
// Consume the message asynchronously.
}
}
```

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.