feat(hydro_test): websocket protocol demo#2128

Draft

shadaj wants to merge 3 commits intomainfrom

Commits on Sep 18, 2025

fix(hydro_lang): ensure that `Stream::scan` actually remembers state with unbounded input
shadaj
committed
feat(hydro_lang): add `flat_map` / `flatten` to `KeyedStream`
shadaj
committed
feat(hydro_test): websocket protocol demo
shadaj
committed