Struct batch_system::batch::Poller

struct Poller<N: Fsm, C: Fsm, Handler> {
    router: Router<N, C, NormalScheduler<N, C>, ControlScheduler<N, C>>,
    fsm_receiver: Receiver<FsmTypes<N, C>>,
    handler: Handler,
    max_batch_size: usize,
    reschedule_duration: Duration,
}

Internal poller that fetches batch and call handler hooks for readiness.

Fields

router: Router<N, C, NormalScheduler<N, C>, ControlScheduler<N, C>>

fsm_receiver: Receiver<FsmTypes<N, C>>

handler: Handler

max_batch_size: usize

reschedule_duration: Duration

Implementations

impl<N: Fsm, C: Fsm, Handler: PollHandler<N, C>> Poller<N, C, Handler>

fn fetch_fsm(&mut self, batch: &mut Batch<N, C>) -> bool

fn poll(&mut self)