1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

use crate::Cell;
use crate::Stream;

pub struct Operational {}

impl Operational {
    pub fn updates<A: Clone + Send + 'static>(ca: &Cell<A>) -> Stream<A> {
        Stream {
            impl_: ca.impl_.updates(),
        }
    }

    pub fn value<A: Clone + Send + 'static>(ca: &Cell<A>) -> Stream<A> {
        Stream {
            impl_: ca.impl_.value(),
        }
    }

    pub fn defer<A: Clone + Send + 'static>(sa: &Stream<A>) -> Stream<A> {
        Stream {
            impl_: sa.impl_.defer(),
        }
    }
}