Trait Broadcast 

pub trait Broadcast<D: ExchangeData> {
    // Required method
    fn broadcast(self) -> Self;
}

Broadcast records to all workers.

Required Methods

fn broadcast(self) -> Self

Broadcast records to all workers.

Examples

use timely::dataflow::operators::{ToStream, Inspect, vec::Broadcast};

timely::example(|scope| {
    (0..10).to_stream(scope)
           .broadcast()
           .inspect(|x| println!("seen: {:?}", x));
});

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<T: Timestamp, D: ExchangeData + Clone> Broadcast<D> for StreamVec<'_, T, D>