Trait timely::dataflow::channels::pact::ParallelizationContract
[−]
[src]
pub trait ParallelizationContract<T: 'static, D: 'static> { fn connect<A: Allocate>(
self,
allocator: &mut A,
identifier: usize
) -> (Box<Push<(T, Content<D>)>>, Box<Pull<(T, Content<D>)>>); }
A ParallelizationContract transforms the output of a Allocate to an (Observer, Pullable).
Required Methods
fn connect<A: Allocate>(
self,
allocator: &mut A,
identifier: usize
) -> (Box<Push<(T, Content<D>)>>, Box<Pull<(T, Content<D>)>>)
self,
allocator: &mut A,
identifier: usize
) -> (Box<Push<(T, Content<D>)>>, Box<Pull<(T, Content<D>)>>)
Alloctes a matched pair of push and pull endpoints implementing the pact.
Implementors
impl<T: 'static, D: 'static> ParallelizationContract<T, D> for Pipeline
impl<T: Eq + Data + Abomonation, D: Data + Abomonation, F: Fn(&D) -> u64 + 'static> ParallelizationContract<T, D> for Exchange<D, F>
impl<T: Eq + Data + Abomonation, D: Data + Abomonation, F: Fn(&T, &D) -> u64 + 'static> ParallelizationContract<T, D> for TimeExchange<D, T, F>