Struct Handle 

pub struct Handle<A, E>
where
    A: Send + 'static,
    E: ActorError,
{ /* private fields */ }

Cloneable handle to send actions to actor A with error type E.

Thread-safe. Actions run sequentially on the actor.

Implementations

impl<A, E> Handle<A, E>

where A: Send + 'static, E: ActorError,

pub fn channel() -> (Self, Receiver<Action<A>>)

Create handle and receiver.

Example

let (handle, rx) = Handle::<MyActor, io::Error>::channel();
spawn_actor(MyActor { state: 0, rx });

pub fn call_blocking<R, F>(&self, f: F) -> Result<R, E>

where F: for<'a> FnOnce(&'a mut A) -> ActorFut<'a, Result<R, E>> + Send + 'static, R: Send + 'static,

Send action, block until complete. Works without async runtime.

Example

handle.call_blocking(act_ok!(actor => async move {
    actor.value += 1;
    actor.value
}))?

Trait Implementations

impl<A, E> Clone for Handle<A, E>

where A: Send + 'static, E: ActorError,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A, E> Debug for Handle<A, E>

where A: Send + 'static + Debug, E: ActorError + Debug,

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

Formats the value using the given formatter.