pub struct Session<'a, T, C, P: Push<Bundle<T, C>> + 'a>{ /* private fields */ }
Expand description
An output session for sending records at a specified time.
The Session
struct provides the user-facing interface to an operator output, namely
the Buffer
type. A Session
wraps a session of output at a specified time, and
avoids what would otherwise be a constant cost of checking timestamp equality.
Implementations§
source§impl<'a, T, C, P: Push<Bundle<T, C>> + 'a> Session<'a, T, C, P>
impl<'a, T, C, P: Push<Bundle<T, C>> + 'a> Session<'a, T, C, P>
sourcepub fn give_container(&mut self, container: &mut C)
pub fn give_container(&mut self, container: &mut C)
Provide a container at the time specified by the Session.
source§impl<'a, T, D, P: Push<Bundle<T, Vec<D>>> + 'a> Session<'a, T, Vec<D>, P>
impl<'a, T, D, P: Push<Bundle<T, Vec<D>>> + 'a> Session<'a, T, Vec<D>, P>
sourcepub fn give_vec(&mut self, message: &mut Vec<D>)
pub fn give_vec(&mut self, message: &mut Vec<D>)
Provides a fully formed Content<D>
message for senders which can use this type.
The Content
type is the backing memory for communication in timely, and it can
often be more efficient to reuse this memory rather than have timely allocate
new backing memory.
Auto Trait Implementations§
impl<'a, T, C, P> Freeze for Session<'a, T, C, P>
impl<'a, T, C, P> RefUnwindSafe for Session<'a, T, C, P>
impl<'a, T, C, P> Send for Session<'a, T, C, P>
impl<'a, T, C, P> Sync for Session<'a, T, C, P>
impl<'a, T, C, P> Unpin for Session<'a, T, C, P>
impl<'a, T, C, P> !UnwindSafe for Session<'a, 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<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
source§fn copy_onto(
self,
target: &mut ConsecutiveOffsetPairs<R, O>
) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
fn copy_onto( self, target: &mut ConsecutiveOffsetPairs<R, O> ) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
Copy self into the target container, returning an index that allows to
look up the corresponding read item.