Struct persist::client::StreamReadHandle [−][src]
pub struct StreamReadHandle<K, V> {
name: String,
stream_id: Result<Id, Error>,
client: RuntimeReadClient,
_phantom: PhantomData<(K, V)>,
}
Expand description
A handle for a persisted stream of ((Key, Value), Time, Diff) updates backed by an crate::indexed::Indexed via a RuntimeClient.
Fields
name: String
stream_id: Result<Id, Error>
client: RuntimeReadClient
_phantom: PhantomData<(K, V)>
Implementations
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
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