pub struct Pipeline;Expand description
A direct connection
Trait Implementations§
Source§impl<T, D> ParallelizationContract<T, D> for Pipelinewhere
T: 'static,
D: 'static,
impl<T, D> ParallelizationContract<T, D> for Pipelinewhere
T: 'static,
D: 'static,
Source§type Pusher = LogPusher<T, D, Pusher<Message<Message<T, D>>, Pusher<Message<Message<T, D>>>>>
type Pusher = LogPusher<T, D, Pusher<Message<Message<T, D>>, Pusher<Message<Message<T, D>>>>>
Type implementing
Push produced by this pact.Source§type Puller = LogPuller<T, D, Puller<Message<Message<T, D>>, Puller<Message<Message<T, D>>>>>
type Puller = LogPuller<T, D, Puller<Message<Message<T, D>>, Puller<Message<Message<T, D>>>>>
Type implementing
Pull produced by this pact.Source§fn connect<A>(
self,
allocator: &mut A,
identifier: usize,
address: &[usize],
logging: Option<Logger<TimelyEvent, usize>>,
) -> (<Pipeline as ParallelizationContract<T, D>>::Pusher, <Pipeline as ParallelizationContract<T, D>>::Puller)where
A: AsWorker,
fn connect<A>(
self,
allocator: &mut A,
identifier: usize,
address: &[usize],
logging: Option<Logger<TimelyEvent, usize>>,
) -> (<Pipeline as ParallelizationContract<T, D>>::Pusher, <Pipeline as ParallelizationContract<T, D>>::Puller)where
A: AsWorker,
Allocates a matched pair of push and pull endpoints implementing the pact.
Auto Trait Implementations§
impl Freeze for Pipeline
impl RefUnwindSafe for Pipeline
impl Send for Pipeline
impl Sync for Pipeline
impl Unpin for Pipeline
impl UnwindSafe for Pipeline
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