hyphae 1.0.3

Reactive cells and runtime primitives for rship
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

use super::{CellValue, TakeExt, TakePipeline};
use crate::pipeline::{Pipeline, Seedness};

#[allow(private_bounds)]
pub trait FirstExt<T: CellValue, S: Seedness>: Pipeline<T, S> {
    /// Take only the first value, then complete. Equivalent to `take(1)`.
    #[track_caller]
    fn first(self) -> TakePipeline<Self, T, S> {
        self.take(1)
    }
}

impl<T: CellValue, S: Seedness, P: Pipeline<T, S>> FirstExt<T, S> for P {}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::{Cell, Gettable, MaterializeDefinite, Mutable, traits::Watchable};

    #[test]
    fn test_first() {
        let source = Cell::new(42);
        let first = source.clone().first().materialize();

        assert_eq!(first.get(), 42);
        assert!(first.is_complete()); // Completes immediately

        source.set(100);
        assert_eq!(first.get(), 42); // Still 42, only takes first
    }
}