1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19

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() }
    }
}