pub fn start_in_arbiter<F>(sys: &ArbiterHandle, f: F) -> Addr<A>
    where
        A: Actor<Context = Context<A>>,
        F: FnOnce(&mut Context<A>) -> A + Send + 'static,
    {
        let (tx, rx) = channel::channel(DEFAULT_CAPACITY);

        sys.spawn_fn(move || {
            let mut ctx = Context::with_receiver(rx);
            let act = f(&mut ctx);
            let fut = ctx.into_future(act);

            actix_rt::spawn(Self { fut });
        });

        Addr::new(tx)
    }
/// Start new supervised actor in arbiter's thread.
Start new supervised actor in arbiter's thread.
Start new supervised actor in arbiter ' s thread .
pub fn start_in_arbiter<F>(sys: &ArbiterHandle, f: F) -> Addr<A>
    where
        A: Actor<Context = Context<A>>,
        F: FnOnce(&mut Context<A>) -> A + Send + 'static,
    {
        let (tx, rx) = channel::channel(DEFAULT_CAPACITY);
        sys.spawn_fn(move || {
            let mut ctx = Context::with_receiver(rx);
            let act = f(&mut ctx);
            let fut = ctx.into_future(act);
            actix_rt::spawn(Self { fut });
        });
        Addr::new(tx)
    }
pub fn start_in_arbiter < F > ( sys : & ArbiterHandle , f : F ) -> Addr < A > where A : Actor < Context = Context < A > > , F : FnOnce ( & mut Context < A > ) -> A + Send + ' static , { let ( tx , rx ) = channel :: channel ( DEFAULT_CAPACITY ) ; sys . spawn_fn ( move | | { let mut ctx = Context :: with_receiver ( rx ) ; let act = f ( & mut ctx ) ; let fut = ctx . into_future ( act ) ; actix_rt :: spawn ( Self { fut } ) ; } ) ; Addr :: new ( tx ) }
Start new supervised actor in arbiter's thread.
Start new supervised actor in arbiter ' s thread .
sys
&ArbiterHandle
f
F
sys
&ArbiterHandle
f
F