async-utility 0.3.1

Collection of async utilities.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

// Copyright (c) 2022-2023 Yuki Kishimoto
// Distributed under the MIT software license

use core::any::Any;
use core::fmt;
use std::thread::Result;

use futures_util::Future;
use tokio::sync::oneshot::{self, Receiver};
use wasm_bindgen_futures::spawn_local;

pub struct JoinHandle<T>(Receiver<T>);

impl<T> JoinHandle<T> {
    pub async fn join(self) -> Result<T> {
        let res = self.0.await;
        res.map_err(|e| Box::new(e) as Box<(dyn Any + Send + 'static)>)
    }
}

impl<T> fmt::Debug for JoinHandle<T> {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.pad("JoinHandle { .. }")
    }
}

pub fn spawn<T>(f: T) -> JoinHandle<T::Output>
where
    T: Future + 'static,
    T::Output: 'static,
{
    let (sender, receiver) = oneshot::channel();

    spawn_local(async {
        let res = f.await;
        sender.send(res).ok();
    });

    JoinHandle(receiver)
}