[][src]Trait rin::prelude::StreamT

pub trait StreamT<'a, T>: WithInner<'a, T> where
    T: Clone + Debug
{ fn rc(self) -> Stream<'a, T>;
fn unique(self) -> Stream<'a, T>; fn on_value<'b, F>(self, f: F) -> Stream<'b, T>
    where
        'a: 'b,
        F: 'b + FnMut(T),
        T: 'a
, { ... }
fn map<'b, 'c, T3, F>(self, f: F) -> Stream<'b, T3>
    where
        'c: 'a,
        'c: 'b,
        'a: 'b,
        F: 'c + FnMut(T) -> T3,
        T: 'a,
        T3: Clone + Debug
, { ... }
fn filter<'b, F>(self, f: F) -> Stream<'b, T>
    where
        'a: 'b,
        F: 'b + FnMut(&T) -> bool,
        T: 'a
, { ... }
fn filter_by<'b, 'c>(self, p: Property<'c, bool>) -> Stream<'b, T>
    where
        'c: 'a,
        'c: 'b,
        'a: 'b,
        T: 'a
, { ... }
fn filter_map<'b, T3, F>(self, f: F) -> Stream<'b, T3>
    where
        'a: 'b,
        F: 'b + FnMut(T) -> Option<T3>,
        T: 'a,
        T3: Clone + Debug
, { ... }
fn flat_map<'b, T3, F>(self, f: F) -> Stream<'b, T3>
    where
        'a: 'b,
        F: 'b + FnMut(T) -> Stream<'b, T3>,
        T: 'a,
        T3: 'b + Clone + Debug
, { ... }
fn take<'b>(self, take: usize) -> Stream<'b, T>
    where
        'a: 'b,
        T: 'a
, { ... }
fn take_then<'b>(self, take: usize, then: T) -> Stream<'b, T>
    where
        'a: 'b,
        T: 'a
, { ... }
fn take_while<'b, F>(self, f: F) -> Stream<'b, T>
    where
        'a: 'b,
        F: 'b + FnMut(T) -> bool,
        T: 'a
, { ... }
fn take_while_then<'b, F>(self, f: F, then: T) -> Stream<'b, T>
    where
        'a: 'b,
        F: 'b + FnMut(T) -> bool,
        T: 'a
, { ... }
fn skip<'b>(self, skip: usize) -> Stream<'b, T>
    where
        'a: 'b,
        T: 'a
, { ... }
fn skip_while<'b, F>(self, f: F) -> Stream<'b, T>
    where
        'a: 'b,
        F: 'b + FnMut(T) -> bool,
        T: 'a
, { ... }
fn fold<'b, T3, F>(self, initial: T3, f: F) -> Stream<'b, T3>
    where
        'a: 'b,
        F: 'b + FnMut(T3, T) -> T3,
        T: 'a,
        T3: Clone + Debug
, { ... }
fn scan<'b, T2, T3, F>(self, initial: T2, f: F) -> Stream<'b, T3>
    where
        'a: 'b,
        F: 'b + FnMut(&mut T2, T) -> Option<T3>,
        T: 'a,
        T2: 'b + Clone + Debug,
        T3: 'b + Clone + Debug
, { ... }
fn dedup<'b>(self) -> Stream<'b, T>
    where
        'a: 'b,
        T: 'a + PartialEq<T>
, { ... }
fn dedup_by<'b, F, T2>(self, f: F) -> Stream<'b, T>
    where
        'a: 'b,
        F: Fn(&T) -> T2 + 'b,
        T: 'a,
        T2: PartialEq<T2> + 'b
, { ... }
fn dedup_or<'b>(self, or: Property<'b, bool>) -> Stream<'b, T>
    where
        'a: 'b,
        T: 'a + PartialEq<T>
, { ... }
fn delay<'b>(self, delay: usize) -> Stream<'b, T>
    where
        'a: 'b,
        T: 'a + PartialEq<T>
, { ... }
fn inspect<'b, F>(self, inspect: F) -> Stream<'b, T>
    where
        'a: 'b,
        F: Fn(T) + 'b,
        T: 'b
, { ... }
fn once<'b, T2>(self, once: T2) -> Stream<'b, T2>
    where
        'a: 'b,
        T: 'a,
        T2: Clone + Debug + 'b
, { ... }
fn merge<'b, 'c, S>(self, other: S) -> Stream<'c, T>
    where
        'a: 'c,
        'b: 'c,
        S: Stream<'b, T>,
        T: 'c
, { ... }
fn throttle<'c>(self, fps: f32) -> Stream<'c, T>
    where
        'a: 'c,
        T: 'a
, { ... }
fn benchmark<'b, 'c, F, S>(
        self,
        frame_stream: S
    ) -> (Stream<'c, T>, Stream<'c, Duration>)
    where
        'a: 'c,
        'b: 'c,
        F: Clone + Debug + 'a + 'b,
        S: Stream<'b, F>,
        T: 'a
, { ... }
fn bandpass<'b>(self, alpha: T) -> Stream<'b, T>
    where
        'a: 'b,
        T: 'a + Zero<Output = T> + One<Output = T> + Sub<T, Output = T> + Add<T> + Mul<T> + Clone
, { ... }
fn resolution<'b>(self, resolution: u8) -> Stream<'b, T>
    where
        'a: 'b,
        T: 'a + Div<T, Output = T> + Mul<T, Output = T> + Float
, { ... }
fn to_bool<'b>(self) -> Stream<'b, bool>
    where
        'a: 'b,
        T: 'a
, { ... }
fn until<'b, 'c, T2, S>(self, until: S) -> Stream<'c, bool>
    where
        'a: 'c,
        'b: 'c,
        S: Stream<'b, T2>,
        T: 'a,
        T2: 'b + Clone + Debug
, { ... }
fn to_property(self, initial: T) -> Property<'a, T>
    where
        Self: Into<Stream<'a, T>>,
        T: 'a
, { ... }
fn iter_async<'b>(self) -> IterAsync<'b, T>
    where
        'a: 'b,
        Self: 'a,
        T: 'a
, { ... }
fn to_parameter(self, initial: T) -> Parameter<'a, T>
    where
        Self: 'a,
        T: 'a
, { ... }
fn to_box(self) -> Box<dyn Stream<'a, T> + 'a>
    where
        Self: 'a
, { ... }
fn collect<'b>(self, samples: usize) -> Property<'b, Vec<T>>
    where
        'a: 'b,
        T: 'a
, { ... } }

Required Methods

Provided Methods

Implementations on Foreign Types

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

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

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

Implementors