Expand description
Local in-memory stream engine using per-subscriber channels.
This implementation is synchronous and uses poll semantics (no async streams) to stay WASM-friendly.
Structsยง
- Local
Stream Engine - Local implementation of
StreamEngineusing per-subscriber channels and poll semantics.