async fn emit_fetched<T: StoreObj + Send + 'static>(
wstore: &Arc<Store>,
event_bus: &Arc<EventBus>,
otype: &'static str,
oid: String,
context: &'static str,
)Expand description
Fetch one StoreObj by oid and broadcast it as a waveobj:update. The
SQLite read is offloaded to the blocking thread pool per ReAgent P1
on PR #852 (Store is std::sync::Mutex<Connection>; brief in
steady state but a long reducer transaction would block the tokio
worker thread). Silently logs + skips on missing/error to satisfy
the §8.15 idempotency contract — duplicate or stale events fold to
no-op.