[−][src]Trait rin::prelude::StreamT
Required Methods
Provided Methods
fn on_value<'b, F>(self, f: F) -> Stream<'b, T> where
'a: 'b,
F: 'b + FnMut(T),
T: 'a,
'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,
'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,
'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,
'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,
'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,
'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,
'a: 'b,
T: 'a,
fn take_then<'b>(self, take: usize, then: T) -> Stream<'b, T> where
'a: 'b,
T: 'a,
'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,
'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,
'a: 'b,
F: 'b + FnMut(T) -> bool,
T: 'a,
fn skip<'b>(self, skip: usize) -> Stream<'b, T> where
'a: 'b,
T: 'a,
'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,
'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,
'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,
'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>,
'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,
'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>,
'a: 'b,
T: 'a + PartialEq<T>,
fn delay<'b>(self, delay: usize) -> Stream<'b, T> where
'a: 'b,
T: 'a + PartialEq<T>,
'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,
'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,
'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,
'a: 'c,
'b: 'c,
S: Stream<'b, T>,
T: 'c,
fn throttle<'c>(self, fps: f32) -> Stream<'c, T> where
'a: 'c,
T: 'a,
'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,
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,
'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,
'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,
'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,
'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,
Self: Into<Stream<'a, T>>,
T: 'a,
fn iter_async<'b>(self) -> IterAsync<'b, T> where
'a: 'b,
Self: 'a,
T: 'a,
'a: 'b,
Self: 'a,
T: 'a,
fn to_parameter(self, initial: T) -> Parameter<'a, T> where
Self: 'a,
T: 'a,
Self: 'a,
T: 'a,
fn to_box(self) -> Box<dyn Stream<'a, T> + 'a> where
Self: 'a,
Self: 'a,
fn collect<'b>(self, samples: usize) -> Property<'b, Vec<T>> where
'a: 'b,
T: 'a,
'a: 'b,
T: 'a,
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,
fn rc(self) -> Stream<'a, T2>
[src]
fn rc(self) -> Stream<'a, T2>
fn unique(self) -> Stream<'a, T2>
[src]
fn unique(self) -> Stream<'a, T2>
fn on_value<'b, F>(self, f: F) -> Stream<'b, T> where
'a: 'b,
F: 'b + FnMut(T),
T: 'a,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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>,
[src]
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,
[src]
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>,
[src]
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>,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
fn collect<'b>(self, samples: usize) -> Property<'b, Vec<T>> where
'a: 'b,
T: 'a,
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,
fn rc(self) -> Stream<'a, T2>
[src]
fn rc(self) -> Stream<'a, T2>
fn unique(self) -> Stream<'a, T2>
[src]
fn unique(self) -> Stream<'a, T2>
fn on_value<'b, F>(self, f: F) -> Stream<'b, T> where
'a: 'b,
F: 'b + FnMut(T),
T: 'a,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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>,
[src]
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,
[src]
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>,
[src]
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>,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
fn collect<'b>(self, samples: usize) -> Property<'b, Vec<T>> where
'a: 'b,
T: 'a,
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]
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,
fn rc(self) -> Stream<'b, T>
[src]
fn rc(self) -> Stream<'b, T>
fn unique(self) -> Stream<'b, T>
[src]
fn unique(self) -> Stream<'b, T>
fn on_value<'b, F>(self, f: F) -> Stream<'b, T> where
'a: 'b,
F: 'b + FnMut(T),
T: 'a,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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>,
[src]
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,
[src]
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>,
[src]
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>,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
fn collect<'b>(self, samples: usize) -> Property<'b, Vec<T>> where
'a: 'b,
T: 'a,