pub struct InputHandleCore<T: Timestamp, C, P: Pull<Message<T, C>>> { /* private fields */ }Expand description
Handle to an operator’s input stream.
Implementations§
Source§impl<T: Timestamp, C: Accountable, P: Pull<Message<T, C>>> InputHandleCore<T, C, P>
impl<T: Timestamp, C: Accountable, P: Pull<Message<T, C>>> InputHandleCore<T, C, P>
Sourcepub fn for_each<F>(&mut self, logic: F)
pub fn for_each<F>(&mut self, logic: F)
Iterates through pairs of capability and container.
The for_each_time method is equivalent, but groups containers by capability and is preferred,
in that it often leads to grouping work by capability, including the creation of output sessions.
Sourcepub fn for_each_time<F>(&mut self, logic: F)
pub fn for_each_time<F>(&mut self, logic: F)
Iterates through distinct capabilities and the lists of containers associated with each.
Auto Trait Implementations§
impl<T, C, P> Freeze for InputHandleCore<T, C, P>where
P: Freeze,
impl<T, C, P> !RefUnwindSafe for InputHandleCore<T, C, P>
impl<T, C, P> !Send for InputHandleCore<T, C, P>
impl<T, C, P> !Sync for InputHandleCore<T, C, P>
impl<T, C, P> Unpin for InputHandleCore<T, C, P>
impl<T, C, P> !UnwindSafe for InputHandleCore<T, C, P>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more