Struct timely::dataflow::channels::pact::Pipeline
[−]
[src]
pub struct Pipeline;
A direct connection
Trait Implementations
impl<T: 'static, D: 'static> ParallelizationContract<T, D> for Pipeline[src]
type Pusher = Pusher<T, D, ThreadPusher<Message<T, D>>>
Type implementing Push produced by this pact.
type Puller = Puller<T, D, ThreadPuller<Message<T, D>>>
Type implementing Pull produced by this pact.
fn connect<A: Allocate>(
self,
allocator: &mut A,
identifier: usize,
logging: Logger
) -> (Self::Pusher, Self::Puller)[src]
self,
allocator: &mut A,
identifier: usize,
logging: Logger
) -> (Self::Pusher, Self::Puller)
Alloctes a matched pair of push and pull endpoints implementing the pact.