[−][src]Trait seitan::StreamT

pub trait StreamT<'a, T: Debug + Clone>: WithInner<'a, T> {
    fn rc(self) -> StreamRc<'a, T>;

    fn unique(self) -> Stream<'a, T>;

    fn on_value<'b, F: FnMut(T) + 'b>(self, f: F) -> Stream<'b, T>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn map<'b, 'c, T3: Debug + Clone, F: 'c + FnMut(T) -> T3>(
        self, 
        f: F
    ) -> Stream<'b, T3>
    where
        T: 'a,
        'c: 'a,
        'c: 'b,
        'a: 'b,
        Self: Sized,
    { ... }

    fn filter<'b, F: FnMut(&T) -> bool + 'b>(self, f: F) -> Stream<'b, T>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn filter_by<'b, 'c>(self, p: Property<'c, bool>) -> Stream<'b, T>
    where
        T: 'a,
        'c: 'a,
        'c: 'b,
        'a: 'b,
        Self: Sized,
    { ... }

    fn filter_map<'b, T3: Debug + Clone, F: FnMut(T) -> Option<T3> + 'b>(
        self, 
        f: F
    ) -> Stream<'b, T3>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn flat_map<'b, T3: Debug + Clone + 'b, F: FnMut(T) -> Stream<'b, T3> + 'b>(
        self, 
        f: F
    ) -> Stream<'b, T3>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn take<'b>(self, take: usize) -> Stream<'b, T>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn take_then<'b>(self, take: usize, then: T) -> Stream<'b, T>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn take_while<'b, F: FnMut(T) -> bool + 'b>(self, f: F) -> Stream<'b, T>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn take_while_then<'b, F: FnMut(T) -> bool + 'b>(
        self, 
        f: F, 
        then: T
    ) -> Stream<'b, T>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn skip<'b>(self, skip: usize) -> Stream<'b, T>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn skip_while<'b, F: FnMut(T) -> bool + 'b>(self, f: F) -> Stream<'b, T>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn fold<'b, T3: Debug + Clone, F: FnMut(T3, T) -> T3 + 'b>(
        self, 
        initial: T3, 
        f: F
    ) -> Stream<'b, T3>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn scan<'b, T2: Debug + Clone + 'b, T3: Debug + Clone + 'b, F: FnMut(&mut T2, T) -> Option<T3> + 'b>(
        self, 
        initial: T2, 
        f: F
    ) -> Stream<'b, T3>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn dedup<'b>(self) -> Stream<'b, T>
    where
        T: 'a + PartialEq,
        'a: 'b,
        Self: Sized,
    { ... }

    fn dedup_by<'b, F, T2>(self, f: F) -> Stream<'b, T>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
        T2: PartialEq + 'b,
        F: Fn(&T) -> T2 + 'b,
    { ... }

    fn dedup_or<'b>(self, or: Property<'b, bool>) -> Stream<'b, T>
    where
        T: 'a + PartialEq,
        'a: 'b,
        Self: Sized,
    { ... }

    fn delay<'b>(self, delay: usize) -> Stream<'b, T>
    where
        T: 'a + PartialEq,
        'a: 'b,
        Self: Sized,
    { ... }

    fn inspect<'b, F>(self, inspect: F) -> Stream<'b, T>
    where
        T: 'b,
        'a: 'b,
        F: Fn(T) + 'b,
        Self: Sized,
    { ... }

    fn once<'b, T2>(self, once: T2) -> Stream<'b, T2>
    where
        T2: Clone + Debug + 'b,
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn merge<'b, 'c, S: Stream<'b, T>>(self, other: S) -> Stream<'c, T>
    where
        T: 'c,
        'a: 'c,
        'b: 'c,
        Self: Sized,
    { ... }

    fn throttle<'c>(self, fps: f32) -> Stream<'c, T>
    where
        T: 'a,
        'a: 'c,
        Self: Sized,
    { ... }

    fn benchmark<'b, 'c, F, S: Stream<'b, F>>(
        self, 
        frame_stream: S
    ) -> (Stream<'c, T>, Stream<'c, Duration>)
    where
        T: 'a,
        'a: 'c,
        'b: 'c,
        F: Clone + Debug + 'a + 'b,
        Self: Sized,
    { ... }

    fn bandpass<'b>(self, alpha: T) -> Stream<'b, T>
    where
        T: 'a + Zero + One + Sub<Output = T> + Add<Output = T> + Mul<Output = T> + Clone,
        'a: 'b,
        Self: Sized,
    { ... }

    fn resolution<'b>(self, resolution: u8) -> Stream<'b, T>
    where
        T: 'a + Div<Output = T> + Mul<Output = T> + Float,
        'a: 'b,
        Self: Sized,
    { ... }

    fn to_bool<'b>(self) -> Stream<'b, bool>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }

    fn until<'b, 'c, T2: Clone + Debug + 'b, S: Stream<'b, T2>>(
        self, 
        until: S
    ) -> Stream<'c, bool>
    where
        Self: Sized,
        T: 'a,
        'a: 'c,
        'b: 'c,
    { ... }

    fn to_property<'b>(self, initial: T) -> Property<'a, T>
    where
        T: 'a,
        Self: Sized + Into<StreamRc<'a, T>>,
    { ... }

    fn iter_async<'b>(self) -> IterAsync<'b, T>
    where
        Self: Sized + 'a,
        T: 'a,
        'a: 'b,
    { ... }

    fn to_parameter(self, initial: T) -> Parameter<'a, T>
    where
        Self: Sized + 'a,
        T: 'a,
    { ... }

    fn to_box(self) -> Box<dyn Stream<'a, T> + 'a>
    where
        Self: Sized + 'a,
    { ... }

    fn collect<'b>(self, samples: usize) -> Property<'b, Vec<T>>
    where
        T: 'a,
        'a: 'b,
        Self: Sized,
    { ... }
}

Required Methods

Provided Methods

ⓘImportant traits for IterAsync<'a, T>

Implementations on Foreign Types

impl<'a, 'b, T: 'b + Debug + Clone, S: WithInner<'a, T> + StreamInner<'a, T>> Stream<'b, T> for &'b S where
    'a: 'b, 
[src]

ⓘImportant traits for IterAsync<'a, T>

Implementors

impl<'a, T2: Clone + Debug> Stream<'a, T2> for seitan::Stream<'a, T2>
[src]

ⓘImportant traits for IterAsync<'a, T>

impl<'a, T2: Clone + Debug> Stream<'a, T2> for seitan::StreamRc<'a, T2>
[src]

ⓘImportant traits for IterAsync<'a, T>