Enum AggregatorCmd

pub enum AggregatorCmd<T: Eq + Hash> {
    NewData(Vec<T>),
    Flush,
}

Variants

NewData(Vec<T>)

Flush

Trait Implementations

impl<T> Handler<AggregatorCmd<T>> for Aggregator<T>

where T: Eq + Hash + Unpin + 'static,

type Result = ()

The type of value that this handler will return.

fn handle( &mut self, msg: AggregatorCmd<T>, ctx: &mut Self::Context, ) -> Self::Result

This method is called for every message received by this actor.

impl<T: Eq + Hash> Message for AggregatorCmd<T>

type Result = ()

The type of value that this message will resolved with if it is successful.