Trait protoflow_core::BlockRuntime

pub trait BlockRuntime: Send + Sync {
    // Required methods
    fn is_alive(&self) -> bool;
    fn sleep_for(&self, duration: Duration) -> Result<(), BlockError>;
    fn sleep_until(&self, instant: Instant) -> Result<(), BlockError>;
    fn wait_for(&self, port: &dyn Port) -> Result<(), BlockError>;
    fn yield_now(&self) -> Result<(), BlockError>;
    fn random_duration(&self, range: Range<Duration>) -> Duration;
}

Required Methods

fn is_alive(&self) -> bool

fn sleep_for(&self, duration: Duration) -> Result<(), BlockError>

fn sleep_until(&self, instant: Instant) -> Result<(), BlockError>

fn wait_for(&self, port: &dyn Port) -> Result<(), BlockError>

fn yield_now(&self) -> Result<(), BlockError>

fn random_duration(&self, range: Range<Duration>) -> Duration

Implementations on Foreign Types

impl<T: Transport> BlockRuntime for Arc<StdRuntime<T>>

fn is_alive(&self) -> bool

fn sleep_for(&self, duration: Duration) -> BlockResult

fn sleep_until(&self, _instant: Instant) -> BlockResult

fn wait_for(&self, _port: &dyn Port) -> BlockResult

fn yield_now(&self) -> Result<(), BlockError>

fn random_duration(&self, range: Range<Duration>) -> Duration

Implementors