Local in-memory stream engine using per-subscriber channels.
This implementation is synchronous and uses poll semantics (no async streams) to stay WASM-friendly.
Local in-memory stream engine using per-subscriber channels.
This implementation is synchronous and uses poll semantics (no async streams) to stay WASM-friendly.