hyphae 1.0.3

Reactive cells and runtime primitives for rship
Documentation
1
2
3
4
5
6
7
8
9
10
11
use super::Watchable;

pub trait Mutable<T>: Watchable<T> {
    fn set(&self, value: T);

    /// Mark this cell as complete. No more values should be emitted after this.
    fn complete(&self);

    /// Mark this cell as errored. No more values will be emitted after this.
    fn fail(&self, error: impl Into<anyhow::Error>);
}