rointe_core/firebase/stream.rs
1//! Phase 2: Firebase RTDB Server-Sent Events (SSE) streaming.
2//!
3//! Will use `eventsource-client` to subscribe to real-time device state
4//! changes, eliminating the need for polling.
5//!
6//! Planned API:
7//! ```ignore
8//! let stream = client.watch_device(device_id).await?;
9//! while let Some(event) = stream.next().await {
10//! match event? {
11//! DeviceEvent::StateChanged(data) => { /* full state */ }
12//! DeviceEvent::FieldUpdated(path, value) => { /* partial update */ }
13//! DeviceEvent::KeepAlive => {}
14//! }
15//! }
16//! ```