flurx 0.1.6

Create reactive asynchronous data flow
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

use core::future::Future;
use core::pin::Pin;
use core::task::{Context, Poll};

use crate::scheduler::Reactor;

#[repr(transparent)]
pub(crate) struct ReactorsFuture<'state, 'future>(pub(crate) &'future mut Option<Reactor<'state>>);


impl<'state, 'future> Future for ReactorsFuture<'state, 'future>

{
    type Output = ();

    #[inline(always)]
    fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
        if self
            .0
            .as_mut()
            .map(|reactor|reactor.as_mut().poll(cx).is_ready())
            .unwrap_or(false){
            self.0.take();
        }
 
        Poll::Ready(())
    }
}