jetty/jetty.project

Jetty 12 - Add a WebSocket MessageSink for Flow.Publisher

Open

#9.722 geöffnet am 2. Mai 2023

Auf GitHub ansehen
 (3 Kommentare) (0 Reaktionen) (0 zugewiesene Personen)Java (1.913 Forks)batch import
EnhancementHelp Wanted

Repository-Metriken

Stars
 (3.701 Stars)
PR-Merge-Metriken
 (Durchschn. Merge 6T 14h) (48 gemergte PRs in 30 T)

Beschreibung

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

Contributor Guide

Research-Richtung
Untersuche die vorhandenen MessageSink Implementierungen für InputStream, um das Muster zu verstehen, und implementiere dann einen ähnlichen Adapter für Flow.Publisher, wobei die Kompatibilität mit der Jetty WebSocket API sichergestellt wird.
Tech Stack
java
Domain
backend
Issue Type
Funktion
SchwierigkeitGeschätzte Implementierungsschwierigkeit für neue Contributors, von 1 für sehr kleine Änderungen bis 5 für Expertenarbeit.
3
Geschätzte ZeitEin grober Zeitrahmen, um zu recherchieren, zu implementieren, zu testen und einen Pull Request vorzubereiten.
Halber Tag
AktivitätsstatusWie verfügbar das Issue gerade wirkt: frisch, aktiv, stale, blockiert oder wartet auf Maintainer-Input.
Aktiv
KlarheitWie klar das Issue die erwartete Änderung, Akzeptanzkriterien und den nächsten Schritt erklärt.
Klar
Voraussetzungen
JavaReactive Streams
EinsteigerfreundlichkeitEin Score von 1 bis 100, der schätzt, wie zugänglich dieses Issue für First-Time Contributors ist.
60