Collected sources and patterns will appear here. Add from search, explore, or the patterns library.
Flux<JsonRpcFrame> -> Mono<JsonRpcResponse>
Demultiplex bidirectional JSON-RPC messages from a single reactive stream into distinct request-response futures and async notifications using reactive streams.
Problem it solves
Handling multiple concurrent, in-flight requests and notifications over a single bidirectional channel without blocking.
Consumes
Emits
The real projects this mechanism was found in. Attribution is the point — this is how the best teams actually do it.