Struct persist::client::RuntimeReadClient [−][src]
pub struct RuntimeReadClient {
sender: CmdReadSender,
stopper: Arc<StopRuntimeOnDrop>,
}
Expand description
A clone-able handle to the read-only persistence runtime.
The runtime is stopped when any client calls RuntimeReadClient::stop or when all clients have been dropped, whichever comes first.
NB: The methods below are executed concurrently. For a some call X to be guaranteed as “previous” to another call Y, X’s future must have been received before Y’s call started (though X’s future doesn’t need to have resolved).
Fields
sender: CmdReadSender
stopper: Arc<StopRuntimeOnDrop>
Implementations
Synchronously loads a stream for reads.
Returns a Description of the stream identified by id_str
.
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for RuntimeReadClient
impl Send for RuntimeReadClient
impl Sync for RuntimeReadClient
impl Unpin for RuntimeReadClient
impl UnwindSafe for RuntimeReadClient
Blanket Implementations
Mutably borrows from an owned value. Read more
Compare self to key
and return true
if they are equal.
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