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::Error: From<Error>, 

pub async fn new<'_>(
    cfg: R::Config,
    rng: &'_ mut dyn CryptoRngCore
) -> 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 dyn CryptoRngCore,
    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 dyn CryptoRngCore)

Processes a single event on the event queue.

pub async fn try_crank<'_, '_>(
    &'_ mut self,
    rng: &'_ mut dyn CryptoRngCore
) -> Option<()>

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

pub async fn run<'_, '_>(&'_ mut self, rng: &'_ mut dyn CryptoRngCore)

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, 

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

Formats the value using the given formatter.