Struct persist::indexed::runtime::StreamReadHandle [−][src]
pub struct StreamReadHandle<K, V> { /* fields omitted */ }
Expand description
A handle for a persisted stream of ((Key, Value), Time, Diff) updates backed by an crate::indexed::Indexed via a RuntimeClient.
Implementations
Returns a new StreamReadHandle for the given stream.
Returns the external stream name for this handle.
Returns a consistent snapshot of all previously persisted stream data.
Registers a callback to be invoked on successful writes and seals.
Also returns a snapshot so that users can, if they choose, perform their logic on everything that was previously persisted before registering the listener, and all writes and seals that happen after registration without duplicating or dropping data.
Trait Implementations
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
Auto Trait Implementations
impl<K, V> !RefUnwindSafe for StreamReadHandle<K, V>
impl<K, V> Send for StreamReadHandle<K, V> where
K: Send,
V: Send,
impl<K, V> Sync for StreamReadHandle<K, V> where
K: Sync,
V: Sync,
impl<K, V> Unpin for StreamReadHandle<K, V> where
K: Unpin,
V: Unpin,
impl<K, V> !UnwindSafe for StreamReadHandle<K, V>
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more