jetty/jetty.project

Jetty 12 - Add a WebSocket MessageSink for Flow.Publisher

Open

#9722 aperta il 2 mag 2023

Vedi su GitHub
 (3 commenti) (0 reazioni) (0 assegnatari)Java (1913 fork)batch import
EnhancementHelp Wanted

Metriche repository

Star
 (3701 star)
Metriche merge PR
 (Merge medio 6g 14h) (48 PR mergiate in 30 g)

Descrizione

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

Guida contributor

Direzione di ricerca
Studia le implementazioni esistenti di MessageSink per InputStream per comprendere il pattern, quindi implementa un adattatore simile per Flow.Publisher, assicurando la compatibilità con l'API WebSocket di Jetty.
Tech stack
java
Dominio
backend
Tipo issue
Funzionalità
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
3
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
Mezza giornata
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
Attiva
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
Chiara
Prerequisiti
JavaReactive Streams
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
60