domcom 0.0.1

Dominator Component Library
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
57
58
59
60
61
62

use std::{
    pin::Pin,
    task::{Context, Poll},
};

use futures_signals::signal::{Mutable, MutableSignalCloned, Signal};

pub struct Mutable2<A, B>(
    (MutableSignalCloned<A>, Mutable<A>),
    (MutableSignalCloned<B>, Mutable<B>),
)
where
    A: Clone,
    B: Clone;
impl<A, B> Mutable2<A, B>
where
    A: Clone,
    B: Clone,
{
    pub fn new(a: Mutable<A>, b: Mutable<B>) -> Self {
        Mutable2((a.signal_cloned(), a), (b.signal_cloned(), b))
    }
}
impl<A, B> Signal for Mutable2<A, B>
where
    A: Clone,
    B: Clone,
{
    type Item = (A, B);

    fn poll_change(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>> {
        let a = Pin::new(&mut self.0 .0).poll_change(cx);
        let b = Pin::new(&mut self.1 .0).poll_change(cx);
        let mut changed = false;

        let left_done = match a {
            Poll::Ready(None) => true,
            Poll::Ready(_) => {
                changed = true;
                false
            }
            Poll::Pending => false,
        };

        let right_done = match b {
            Poll::Ready(None) => true,
            Poll::Ready(_) => {
                changed = true;
                false
            }
            Poll::Pending => false,
        };

        if changed {
            Poll::Ready(Some((self.0 .1.get_cloned(), self.1 .1.get_cloned())))
        } else if left_done && right_done {
            Poll::Ready(None)
        } else {
            Poll::Pending
        }
    }
}