Struct fp_rust::actor::ActorAsync [−][src]
pub struct ActorAsync<Msg, ContextValue> where
Msg: Send + 'static, { /* fields omitted */ }
Implementations
pub fn new(
effect: impl FnMut(&mut ActorAsync<Msg, ContextValue>, Msg, &mut HashMap<String, ContextValue>) + Send + Sync + 'static
) -> Self
pub fn new_with_options(
effect: impl FnMut(&mut ActorAsync<Msg, ContextValue>, Msg, &mut HashMap<String, ContextValue>) + Send + Sync + 'static,
parent_handle: Option<HandleAsync<Msg>>,
queue: BlockingQueue<Msg>
) -> Self
impl<Msg, ContextValue> ActorAsync<Msg, ContextValue> where
Msg: Clone + Send + 'static,
ContextValue: Send + 'static,
impl<Msg, ContextValue> ActorAsync<Msg, ContextValue> where
Msg: Clone + Send + 'static,
ContextValue: Send + 'static,
Trait Implementations
impl<Msg, ContextValue> Actor<Msg, ContextValue, HandleAsync<Msg>, Box<dyn FnMut(&mut ActorAsync<Msg, ContextValue>, Msg, &mut HashMap<String, ContextValue, RandomState>) + Send + Sync + 'static, Global>> for ActorAsync<Msg, ContextValue> where
Msg: Clone + Send + 'static,
ContextValue: Send + 'static,
impl<Msg, ContextValue> Actor<Msg, ContextValue, HandleAsync<Msg>, Box<dyn FnMut(&mut ActorAsync<Msg, ContextValue>, Msg, &mut HashMap<String, ContextValue, RandomState>) + Send + Sync + 'static, Global>> for ActorAsync<Msg, ContextValue> where
Msg: Clone + Send + 'static,
ContextValue: Send + 'static,
fn spawn_with_handle(
&self,
func: Box<dyn FnMut(&mut ActorAsync<Msg, ContextValue>, Msg, &mut HashMap<String, ContextValue>) + Send + Sync + 'static>
) -> HandleAsync<Msg>
impl<Msg, ContextValue> Clone for ActorAsync<Msg, ContextValue> where
Msg: Clone + Send + 'static,
impl<Msg, ContextValue> Clone for ActorAsync<Msg, ContextValue> where
Msg: Clone + Send + 'static,
Auto Trait Implementations
impl<Msg, ContextValue> RefUnwindSafe for ActorAsync<Msg, ContextValue>
impl<Msg, ContextValue> Send for ActorAsync<Msg, ContextValue> where
ContextValue: Send,
impl<Msg, ContextValue> Sync for ActorAsync<Msg, ContextValue> where
ContextValue: Send,
impl<Msg, ContextValue> Unpin for ActorAsync<Msg, ContextValue>
impl<Msg, ContextValue> UnwindSafe for ActorAsync<Msg, ContextValue>
Blanket Implementations
Mutably borrows from an owned value. Read more