Struct PollActor 

pub struct PollActor<H: CdcHost, C: CdcConsume> { /* private fields */ }

Implementations

impl<H: CdcHost, C: CdcConsume> PollActor<H, C>

pub fn new( config: PollActorConfig, host: H, consumer: C, store: CdcStore, ) -> Self

Create a new poll actor

Trait Implementations

impl<H: CdcHost, C: CdcConsume + Send + Sync + 'static> Actor for PollActor<H, C>

type State = PollState

The actor’s internal state (owned, not shared).

type Message = CdcPollMessage

Messages this actor can receive.

fn init(&self, ctx: &Context<Self::Message>) -> Self::State

Create initial state. Called on start and restart.

fn handle( &self, state: &mut Self::State, msg: Self::Message, ctx: &Context<Self::Message>, ) -> Directive

Handle a single message. This is the core of the actor.

fn config(&self) -> ActorConfig

Actor configuration. Override for custom settings.

fn idle(&self, ctx: &Context<Self::Message>) -> Directive

Called when the mailbox is empty.

fn post_stop(&self)

Called once after actor stops (always called, even on panic).