[−][src]Trait timely::dataflow::channels::pact::ParallelizationContract
A ParallelizationContract
allocates paired Push
and Pull
implementors.
Associated Types
type Pusher: Push<Bundle<T, D>> + 'static
Type implementing Push
produced by this pact.
type Puller: Pull<Bundle<T, D>> + 'static
Type implementing Pull
produced by this pact.
Required methods
fn connect<A: AsWorker>(
self,
allocator: &mut A,
identifier: usize,
address: &[usize],
logging: Option<Logger>
) -> (Self::Pusher, Self::Puller)
self,
allocator: &mut A,
identifier: usize,
address: &[usize],
logging: Option<Logger>
) -> (Self::Pusher, Self::Puller)
Allocates a matched pair of push and pull endpoints implementing the pact.
Implementors
impl<T: 'static, D: 'static> ParallelizationContract<T, D> for Pipeline
[src]
type Pusher = LogPusher<T, D, ThreadPusher<Bundle<T, D>>>
type Puller = LogPuller<T, D, ThreadPuller<Bundle<T, D>>>
fn connect<A: AsWorker>(
self,
allocator: &mut A,
identifier: usize,
address: &[usize],
logging: Option<Logger>
) -> (Self::Pusher, Self::Puller)
[src]
self,
allocator: &mut A,
identifier: usize,
address: &[usize],
logging: Option<Logger>
) -> (Self::Pusher, Self::Puller)