ps-promise 0.1.0-17

Promise-like owned futures
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

use std::{
    future::Future,
    pin::Pin,
    task::{
        Context,
        Poll::{self, Pending, Ready},
    },
};

use crate::{PromiseRejection, TaskFailure};

use super::super::AbortablePromise;

impl<T, E> Future for AbortablePromise<T, E>
where
    E: PromiseRejection,
{
    type Output = Result<T, E>;

    fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
        let aborted = || Ready(Err(E::task_failed(TaskFailure::Aborted)));
        let this = self.get_mut();

        this.receiver.poll(cx);

        if this.receiver.is_resolved() {
            return aborted();
        }

        this.inner.poll(cx);
        this.receiver.poll(cx);

        if this.receiver.is_resolved() {
            aborted()
        } else if let Some(result) = this.inner.consume() {
            Ready(result)
        } else {
            Pending
        }
    }
}