atomr-core 0.1.0

Actors, supervision, dispatch, mailboxes, scheduler, FSM, event stream, and coordinated shutdown — the core of the atomr actor runtime.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

//! Re-export of the `ask` pattern. Mirrors akka.net `AskSupport.cs`.
//!
//! The primary API lives on [`crate::actor::ActorRef::ask_with`]; this free
//! function is a convenience wrapper so users can write
//! `ask(&target, |reply| Msg::Query(reply), Duration::from_secs(1)).await`.

use std::time::Duration;

use tokio::sync::oneshot;

use crate::actor::{ActorRef, AskError};

pub async fn ask<M: Send + 'static, R: Send + 'static, F>(
    target: &ActorRef<M>,
    build: F,
    timeout: Duration,
) -> Result<R, AskError>
where
    F: FnOnce(oneshot::Sender<R>) -> M,
{
    target.ask_with(build, timeout).await
}