Jetty 12 - Add a WebSocket MessageSink for Flow.Publisher
Open
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
Assessment
This issue has not been assessed yet.