Struct Reader 

pub struct Reader {
    pub db: Arc<Db>,
    pub addr: Recipient<ReadEventResult>,
    pub setting: SettingWrapper,
}

Requst by filter Concurrent read events from db

Fields

db: Arc<Db>

addr: Recipient<ReadEventResult>

setting: SettingWrapper

Implementations

impl Reader

pub fn new( db: Arc<Db>, addr: Recipient<ReadEventResult>, setting: SettingWrapper, ) -> Self

pub fn read(&self, msg: &ReadEvent) -> Result<()>

Trait Implementations

impl Actor for Reader

type Context = SyncContext<Reader>

Actor execution context type

fn started(&mut self, _ctx: &mut Self::Context)

Called when an actor gets polled the first time.

fn stopping(&mut self, ctx: &mut Self::Context) -> Running

Called after an actor is in Actor::Stopping state.

fn stopped(&mut self, ctx: &mut Self::Context)

Called after an actor is stopped.

impl Handler<ReadEvent> for Reader

type Result = ()

The type of value that this handler will return.

fn handle(&mut self, msg: ReadEvent, _: &mut Self::Context)

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