Struct persist::operators::input::PersistentUnorderedSession [−][src]
pub struct PersistentUnorderedSession<'b, K: Data> {
write: &'b mut Box<StreamWriteHandle<K, ()>>,
session: ActivateOnDrop<AutoflushSession<'b, u64, (K, u64, isize), Counter<u64, (K, u64, isize), Tee<u64, (K, u64, isize)>>>>,
}
Expand description
A persistent equivalent of UnorderedHandle::session’s return type.
Fields
write: &'b mut Box<StreamWriteHandle<K, ()>>
session: ActivateOnDrop<AutoflushSession<'b, u64, (K, u64, isize), Counter<u64, (K, u64, isize), Tee<u64, (K, u64, isize)>>>>
Implementations
Auto Trait Implementations
impl<'b, K> !RefUnwindSafe for PersistentUnorderedSession<'b, K>
impl<'b, K> !Send for PersistentUnorderedSession<'b, K>
impl<'b, K> !Sync for PersistentUnorderedSession<'b, K>
impl<'b, K> Unpin for PersistentUnorderedSession<'b, K>
impl<'b, K> !UnwindSafe for PersistentUnorderedSession<'b, K>
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