This demo reads from a WebSocket stream of Wikipedia Recent Changes and, after a fake processing step that takes one second, echos the result back to another WebSocket server.
Open the DevTools of your browser to see the in- and outgoing WebSocket traffic. On Chrome, you can filter the Network tab to just show WebSocket data.
Find the source code on GitHub.
This part of the demo
reads
from a
WebSocketStream
of recent Wikipedia changes
and
writes
each message back to a different echo
WebSocketStream.
✅ Backpressure is applied to both read and write operations. The next message is only read once the pipeline is ready.