Struct actix::msgs::Execute

pub struct Execute<I: Send + 'static = (), E: Send + 'static = ()>(_);

Execute function in arbiter's thread

Arbiter` actor handles Execute message.

Example

use actix::prelude::*;

struct MyActor{addr: SyncAddress<Arbiter>}

impl Actor for MyActor {
   type Context = Context<Self>;

   fn started(&mut self, ctx: &mut Context<Self>) {
       self.addr.send(actix::msgs::Execute::new(|| -> Result<(), ()> {
           // do something
           // ...
           Ok(())
       }));
   }
}
fn main() {}

Methods

impl<I, E> Execute<I, E> where
    I: Send + 'static,
    E: Send + 'static, 

fn new<F>(f: F) -> Self where
    F: FnOnce() -> Result<I, E> + Send + 'static, 

fn exec(self) -> Result<I, E>

Execute enclosed function

Trait Implementations

impl<I: Send, E: Send> ResponseType for Execute<I, E>

Execute message response

type Item = I

The type of value that this message will resolved with if it is successful.

type Error = E

The type of error that this message will resolve with if it fails in a normal fashion.