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_stamp method is equivalent, but groups containers by stamp and is preferred,
in that it often leads to grouping work by stamp, including the creation of output sessions.
Sourcepub fn for_each_stamp<F>(&mut self, logic: F)
pub fn for_each_stamp<F>(&mut self, logic: F)
Iterates through distinct stamps, each with a capability and the containers received under it.
Containers are grouped by the stamp of their message, the set of timestamps under which it travels; the capability covers exactly that stamp.
Sourcepub fn for_each_time<F>(&mut self, logic: F)
👎Deprecated: renamed to for_each_stamp: containers are grouped by stamp, not by a time
pub fn for_each_time<F>(&mut self, logic: F)
renamed to for_each_stamp: containers are grouped by stamp, not by a time
Iterates through distinct stamps; renamed to for_each_stamp.
Auto Trait Implementations§
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> !UnwindSafe for InputHandleCore<T, C, P>
impl<T, C, P> Freeze for InputHandleCore<T, C, P>
impl<T, C, P> Unpin for InputHandleCore<T, C, P>
impl<T, C, P> UnsafeUnpin for InputHandleCore<T, C, P>where
Counter<T, C, P>: UnsafeUnpin,
Rc<RefCell<Vec<Rc<RefCell<ChangeBatch<T>>>>>>: UnsafeUnpin,
Rc<OnceCell<PortConnectivity<<T as Timestamp>::Summary>>>: UnsafeUnpin,
VecDeque<(InputCapability<T>, C)>: UnsafeUnpin,
Vec<C>: UnsafeUnpin,
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