tcio 0.1.0

Collection of utility types.
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

use std::pin::Pin;

/// Map a [`Future`] output.
///
/// # Example
///
/// ```
/// # async fn app() {
/// use tcio::futures::map;
/// let fut = async { 112 };
/// let result = map(fut, |e| e.to_string()).await;
/// assert_eq!(&result[..], "112");
/// # }
/// # assert!(matches!(
/// #     std::pin::pin!(app())
/// #         .poll(&mut std::task::Context::from_waker(std::task::Waker::noop())),
/// #     std::task::Poll::Ready(())
/// # ));
/// ```
#[inline]
pub fn map<F, M, O>(f: F, map: M) -> Map<F, M>
where
    F: Future,
    M: FnOnce(F::Output) -> O,
{
    Map { f, map: Some(map) }
}

/// Future returned by [`map`].
#[derive(Debug)]
pub struct Map<F, M> {
    f: F,
    map: Option<M>,
}

impl<F, M, O> Future for Map<F, M>
where
    F: Future,
    M: FnOnce(F::Output) -> O,
{
    type Output = O;

    #[inline]
    fn poll(
        self: Pin<&mut Self>,
        cx: &mut std::task::Context<'_>,
    ) -> std::task::Poll<Self::Output> {
        // SAFETY: self is pinned
        // no `Drop`, nor manual `Unpin` implementation.
        let (f, map) = unsafe {
            let me = self.get_unchecked_mut();
            (Pin::new_unchecked(&mut me.f), &mut me.map)
        };
        f.poll(cx).map(map.take().expect("poll after complete"))
    }
}