Struct casper_node::reactor::Runner

pub struct Runner<R> where
    R: Reactor,  { /* fields omitted */ }

A runner for a reactor.

The runner manages a reactors event queue and reactor itself and can run it either continuously or in a step-by-step manner.

Implementations

impl<R> Runner<R> where
    R: Reactor,
    R::Event: Serialize,
    R::Error: From<Error>, 

pub async fn new(cfg: R::Config, rng: &mut NodeRng) -> Result<Self, R::Error>

Creates a new runner from a given configuration.

Creates a metrics registry that is only going to be used in this runner.

pub async fn with_metrics(
    cfg: R::Config,
    rng: &mut NodeRng,
    registry: &Registry
) -> Result<Self, R::Error>

Creates a new runner from a given configuration, using existing metrics.

pub async fn crank(&mut self, rng: &mut NodeRng)

Processes a single event on the event queue.

pub async fn try_crank(&mut self, rng: &mut NodeRng) -> Option<()>

Processes a single event if there is one, returns None otherwise.

pub async fn run(&mut self, rng: &mut NodeRng)

Runs the reactor until is_stopped() returns true.

pub fn reactor(&self) -> &R

Returns a reference to the reactor.

pub fn reactor_mut(&mut self) -> &mut R

Returns a mutable reference to the reactor.

pub fn into_inner(self) -> R

Deconstructs the runner to return the reactor.

Trait Implementations

impl<R: Debug> Debug for Runner<R> where
    R: Reactor,
    R::Event: Debug, 

pub fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.