Trait ReactorExt 

pub trait ReactorExt<T, S = ()>: Reactor<T, S> {
    // Provided method
    fn react_to_data_record(
        &mut self,
        record: T,
    ) -> Result<Self::Response, Self::Error>
       where S: Default { ... }
}

Extension methods for Reactor types.

Provided Methods

fn react_to_data_record( &mut self, record: T, ) -> Result<Self::Response, Self::Error>

where S: Default,

Reacts to a data record.

This function constructs and reacts to a data event with the given record at Timestamp::now.

Implementors

impl<R, T> ReactorExt<T> for R

where R: Reactor<T, ()>,