oxide_core 0.4.0

Rust engine primitives for Oxide (store, snapshot streams, error model, optional persistence).
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use tokio::sync::watch;
use tokio_stream::wrappers::WatchStream;

// Stream adapter helpers for FFI.
//
// Why: many binding layers want a `Stream`-like API rather than a `watch::Receiver`.
// How: `tokio_stream` provides a small wrapper that keeps semantics consistent.
/// Converts a [`watch::Receiver`] into a [`WatchStream`].
///
/// This can be useful when exposing store updates to stream-based consumers.
///
/// # Returns
/// A stream that yields the current value immediately and then yields on changes.
pub fn watch_receiver_to_stream<T>(rx: watch::Receiver<T>) -> WatchStream<T>
where
    T: Clone + Send + Sync + 'static,
{
    WatchStream::new(rx)
}