Trait ParallelizationContract 

pub trait ParallelizationContract<T, C> {
    type Pusher: Push<Message<T, C>> + 'static;
    type Puller: Pull<Message<T, C>> + 'static;

    // Required method
    fn connect(
        self,
        worker: &Worker,
        identifier: usize,
        address: Rc<[usize]>,
        logging: Option<Logger>,
    ) -> (Self::Pusher, Self::Puller);
}

A ParallelizationContract allocates paired Push and Pull implementors.

Required Associated Types

type Pusher: Push<Message<T, C>> + 'static

Type implementing Push produced by this pact.

type Puller: Pull<Message<T, C>> + 'static

Type implementing Pull produced by this pact.

Required Methods

fn connect( self, worker: &Worker, identifier: usize, address: Rc<[usize]>, logging: Option<Logger>, ) -> (Self::Pusher, Self::Puller)

Allocates a matched pair of push and pull endpoints implementing the pact.

Implementors

impl<T, B, C, D> ParallelizationContract<T, C> for DistributorPact<B>

where T: Timestamp, B: FnOnce(usize) -> D, C: Accountable + ContainerBytes + Send + 'static, D: Distributor<C> + 'static,

type Pusher = Exchange<T, LogPusher<Box<dyn Push<Message<T, C>>>>, D>

type Puller = LogPuller<Box<dyn Pull<Message<T, C>>>>

impl<T: 'static, C: Accountable + 'static> ParallelizationContract<T, C> for Pipeline

type Pusher = LogPusher<Pusher<Message<T, C>, Pusher<Message<T, C>>>>

type Puller = LogPuller<Puller<Message<T, C>, Puller<Message<T, C>>>>