Trait Input

pub trait Input: DispatcherMessageStream {
    // Required method
    fn actor_id(&self) -> ActorId;

    // Provided method
    fn boxed_input(self) -> BoxedInput
       where Self: Sized + 'static { ... }
}

Input provides an interface for MergeExecutor and ReceiverExecutor to receive data from upstream actors.

Required Methods

fn actor_id(&self) -> ActorId

The upstream actor id.

Provided Methods

fn boxed_input(self) -> BoxedInput

where Self: Sized + 'static,

Trait Implementations

impl Debug for dyn Input

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

Formats the value using the given formatter.

Implementors

impl Input for LocalInput

impl Input for RemoteInput