Wow Simone, complimenti per il risultato. WebSocket.Listener può essere implementata come una specializzazione di Flow.Subscriber con il metodo onNext() che ritorna un CompletitionStage, cioé un onNext() capace di notificare quando il messaggio è stato consumato, esattamente quello che ha chiesto Luigi.
Se fosse possibile rilasciare esplicitamente le risorse di tipo ByteBuffer e CharSequence (come per Netty) non ci sarebbe stato bisogno di questa specializzazione e Luigi avrebbe potuto semplicemente utilizzare un ByteBufferPool (similmente a Netty). I WebSocket potrebbero essere consumati come Stream Reattivi, invece è stata riscritta una interfaccia ad-hoc incompatibile con Subscriber. Inoltre non è neanche possibile scrivere un adattatore di Flow.Subscriber per WebSocket.Listener poiché non è possibile comunicare quando la risorsa sia consumata, a meno di non farsi una copia di tutti i messaggi ricevuti. È il problema che stiamo discutendo, io vedo molte similitudini. Ciao, Vasco
