Asynchronous composer for Rust.
primitive thunk:
rust
let thunk: Thunk<i32, &str> = Thunk::new(|cb| {
thread::spawn(move || {
thread::sleep(Duration::new(3, 0));
cb(Ok(1));
});
});
let res = thunk.await().unwrap();
assert_eq!(res, 1);
Sequence control:
rust
let thunk_vec: Vec<Thunk<i32, &str>> = vec![
Thunk::new(|cb| {
thread::spawn(move || {
thread::sleep(Duration::new(1, 0));
cb(Ok(1));
});
}),
Thunk::new(|cb| {
thread::spawn(move || {
thread::sleep(Duration::new(1, 0));
cb(Ok(2));
});
}),
Thunk::new(|cb| {
thread::spawn(move || {
thread::sleep(Duration::new(1, 0));
cb(Ok(3));
});
})
];
let res = Thunk::seq(thunk_vec).await().unwrap();
assert_eq!(res, vec![1, 2, 3]);
Parallel control:
rust
let thunk_vec: Vec<Thunk<i32, &str>> = vec![
Thunk::new(|cb| {
thread::spawn(move || {
thread::sleep(Duration::new(1, 0));
cb(Ok(1));
});
}),
Thunk::new(|cb| {
thread::spawn(move || {
thread::sleep(Duration::new(1, 0));
cb(Ok(2));
});
}),
Thunk::new(|cb| {
thread::spawn(move || {
thread::sleep(Duration::new(1, 0));
cb(Ok(3));
});
})
];
let res = Thunk::all(thunk_vec).await().unwrap();
assert_eq!(res, vec![1, 2, 3]);
rust
extern crate thunks;
use thunks::Thunk;
rust
pub struct Thunk<T, E>(_)
impl<T, E> Thunk<T, E> where T: Send + 'static, E: Send + 'staticrust
fn new<F>(task: F) -> Thunk<T, E>
where F: Fn(Box<Fn(Result<T, E>) + Send + 'static>) + Send + 'static
rust
fn seq(thunk_vec: Vec<Thunk<T, E>>) -> Thunk<Vec<T>, E>
rust
fn all(thunk_vec: Vec<Thunk<T, E>>) -> Thunk<Vec<T>, E>
rust
fn await(&self) -> Result<T, E>