Struct differential_dataflow::operators::arrange::writer::TraceWriter
source · pub struct TraceWriter<Tr>{ /* private fields */ }
Expand description
Write endpoint for a sequence of batches.
A TraceWriter
accepts a sequence of batches and distributes them
to both a shared trace and to a sequence of private queues.
Implementations§
source§impl<Tr> TraceWriter<Tr>
impl<Tr> TraceWriter<Tr>
sourcepub fn new(
upper: Vec<Tr::Time>,
trace: Weak<RefCell<TraceBox<Tr>>>,
queues: Rc<RefCell<Vec<Weak<(Activator, RefCell<VecDeque<TraceReplayInstruction<Tr>>>)>>>>
) -> Self
pub fn new( upper: Vec<Tr::Time>, trace: Weak<RefCell<TraceBox<Tr>>>, queues: Rc<RefCell<Vec<Weak<(Activator, RefCell<VecDeque<TraceReplayInstruction<Tr>>>)>>>> ) -> Self
Creates a new TraceWriter
.
Trait Implementations§
Auto Trait Implementations§
impl<Tr> Freeze for TraceWriter<Tr>
impl<Tr> !RefUnwindSafe for TraceWriter<Tr>
impl<Tr> !Send for TraceWriter<Tr>
impl<Tr> !Sync for TraceWriter<Tr>
impl<Tr> Unpin for TraceWriter<Tr>
impl<Tr> !UnwindSafe for TraceWriter<Tr>
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.