Expand description
SurrealDB-backed live-query bus.
Opens one .select(table).live() stream per EntityTopic at startup and
forwards Notification<Value> events into a per-topic broadcast channel.
SSE handlers subscribe to the receiver side. Streams are wrapped in a
supervised reconnect loop with exponential backoff to survive transient
SurrealDB disconnects.