Struct stress_test::actor::ActorRunner

pub struct ActorRunner {
    pub name: String,
    pub delay: Option<Duration>,
    pub actor: Arc<Mutex<dyn Actor>>,
}

The thread that runs an actor indefinitely

Fields

name: String

delay: Option<Duration>

actor: Arc<Mutex<dyn Actor>>

Implementations

impl ActorRunner

pub fn new<A: Actor>( name: impl ToString, delay: Option<Duration>, actor: Arc<Mutex<A>> ) -> Self

pub fn run( self, counter_tx: UnboundedSender<String>, generation: u64 ) -> (Task<Result<(ActorRunner, u64), Aborted>>, AbortHandle)

Run the actor in a new task indefinitely for the given generation. The runner will stop if the actor requests an environment reset. The amount of parallelism is determined by the caller’s executor.

Trait Implementations

impl Clone for ActorRunner

fn clone(&self) -> ActorRunner

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.