Struct BroadcastDispatcher

pub struct BroadcastDispatcher {
    outputs: HashMap<ActorId, BoxedOutput>,
    output_indices: Vec<usize>,
    dispatcher_id: DispatcherId,
    dispatcher_id_str: String,
}

BroadcastDispatcher dispatches message to all outputs.

Fields

outputs: HashMap<ActorId, BoxedOutput>

output_indices: Vec<usize>

dispatcher_id: DispatcherId

dispatcher_id_str: String

Implementations

impl BroadcastDispatcher

pub fn new( outputs: impl IntoIterator<Item = BoxedOutput>, output_indices: Vec<usize>, dispatcher_id: DispatcherId, ) -> Self

fn into_pairs( outputs: impl IntoIterator<Item = BoxedOutput>, ) -> impl Iterator<Item = (ActorId, BoxedOutput)>

Trait Implementations

impl Debug for BroadcastDispatcher

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Dispatcher for BroadcastDispatcher

async fn dispatch_data(&mut self, chunk: StreamChunk) -> StreamResult<()>

Dispatch a data chunk to downstream actors.

async fn dispatch_barrier( &mut self, barrier: DispatcherBarrier, ) -> StreamResult<()>

Dispatch a barrier to downstream actors, generally by broadcasting it.

async fn dispatch_watermark(&mut self, watermark: Watermark) -> StreamResult<()>

Dispatch a watermark to downstream actors, generally by broadcasting it.

fn add_outputs(&mut self, outputs: impl IntoIterator<Item = BoxedOutput>)

Add new outputs to the dispatcher.

fn remove_outputs(&mut self, actor_ids: &HashSet<ActorId>)

Remove outputs to actor_ids from the dispatcher.

fn dispatcher_id(&self) -> DispatcherId

The ID of the dispatcher. A DispatchExecutor may have multiple dispatchers with different IDs.

fn dispatcher_id_str(&self) -> &str

Dispatcher id in string. See Dispatcher::dispatcher_id.

fn is_empty(&self) -> bool

Whether the dispatcher has no outputs. If so, it’ll be cleaned up from the DispatchExecutor.