Struct persist::operators::input::PersistentUnorderedHandle [−][src]
pub struct PersistentUnorderedHandle<K: TimelyData> {
write: Box<StreamWriteHandle<K, ()>>,
handle: UnorderedHandle<u64, (K, u64, isize)>,
}
Expand description
A persistent equivalent of UnorderedHandle.
Fields
write: Box<StreamWriteHandle<K, ()>>
handle: UnorderedHandle<u64, (K, u64, isize)>
Implementations
pub fn session<'b>(
&'b mut self,
cap: ActivateCapability<u64>
) -> PersistentUnorderedSession<'b, K>
pub fn session<'b>(
&'b mut self,
cap: ActivateCapability<u64>
) -> PersistentUnorderedSession<'b, K>
A persistent equivalent of UnorderedHandle::session.
Trait Implementations
Auto Trait Implementations
impl<K> !RefUnwindSafe for PersistentUnorderedHandle<K>
impl<K> !Send for PersistentUnorderedHandle<K>
impl<K> !Sync for PersistentUnorderedHandle<K>
impl<K> Unpin for PersistentUnorderedHandle<K> where
K: Unpin,
impl<K> !UnwindSafe for PersistentUnorderedHandle<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