Struct timely::dataflow::channels::pushers::exchange::Exchange

pub struct Exchange<T, D, P: Push<(T, Content<D>)>, H: Fn(&T, &D) -> u64> { /* fields omitted */ }

Distributes records among target pushees according to a distribution function.

Methods

impl<T: Clone, D, P: Push<(T, Content<D>)>, H: Fn(&T, &D) -> u64> Exchange<T, D, P, H>

pub fn new(pushers: Vec<P>, key: H) -> Exchange<T, D, P, H>

Allocates a new Exchange from a supplied set of pushers and a distribution function.

Trait Implementations

impl<T: Eq + Clone + 'static, D: Data + Abomonation, P: Push<(T, Content<D>)>, H: Fn(&T, &D) -> u64> Push<(T, Content<D>)> for Exchange<T, D, P, H>

fn push(&mut self, message: &mut Option<(T, Content<D>)>)

Pushes element and provides the opportunity to take ownership.

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.