Struct seitan::Stream [−][src]
#[must_use = "droping a stream unsubscribes it and all the chain until the origin sender"]pub struct Stream<'a, T2> { /* fields omitted */ }
Implementations
impl<'a, T2> Stream<'a, T2>
[src]
impl<'a, T2> Stream<'a, T2>
[src]pub fn from_parent<'p, T1, S: StreamExt<'p, T1>, Inner: StreamInner<'a, T2> + SinkInner<'a, T1> + 'a>(
parent: S,
inner: Rc<UnsafeCell<Inner>>
) -> Stream<'a, T2>
[src]
parent: S,
inner: Rc<UnsafeCell<Inner>>
) -> Stream<'a, T2>
pub fn from_remove<'p, T1, S: Remove + 'a, Inner: StreamInner<'a, T2> + SinkInner<'a, T1> + 'a>(
remove: S,
inner: Rc<UnsafeCell<Inner>>
) -> Stream<'a, T2>
[src]
remove: S,
inner: Rc<UnsafeCell<Inner>>
) -> Stream<'a, T2>
pub fn new<Inner: StreamInner<'a, T2> + 'a>(
inner: Rc<UnsafeCell<Inner>>
) -> Stream<'a, T2>
[src]
inner: Rc<UnsafeCell<Inner>>
) -> Stream<'a, T2>
pub fn send(&self, t: T2)
[src]
pub fn on_drop(self, value: T2) -> Stream<'a, T2>
[src]
impl<'a, T2: 'a> Stream<'a, T2>
[src]
impl<'a, T2: 'a> Stream<'a, T2>
[src]impl<'a, T2: Clone + 'a> Stream<'a, T2>
[src]
impl<'a, T2: Clone + 'a> Stream<'a, T2>
[src]pub fn connect_to_property<'b, 'c>(
self,
property: &mut Property<'a, T2>
) -> Stream<'a, T2> where
T2: 'c,
Self: Sized,
[src]
self,
property: &mut Property<'a, T2>
) -> Stream<'a, T2> where
T2: 'c,
Self: Sized,
pub fn connect_to_property_last_value<'b, 'c>(
self,
property: &mut PropertyLastValue<'a, T2>
) -> Stream<'a, T2> where
T2: 'c,
Self: Sized,
[src]
self,
property: &mut PropertyLastValue<'a, T2>
) -> Stream<'a, T2> where
T2: 'c,
Self: Sized,
pub fn swap_parent<S: StreamExt<'a, T2>>(&mut self, parent: S)
[src]
impl<'a> Stream<'a, f64>
[src]
impl<'a> Stream<'a, f64>
[src]pub fn connect_to_ranged_parameter_pct<T, R>(
self,
param: &mut RangedPropertyMut<'a, T, R>
) -> Stream<'a, T> where
T: Clone + FromPrimitive + ToPrimitive,
R: Sub<Output = R> + ToPrimitive + Clone + 'static,
[src]
self,
param: &mut RangedPropertyMut<'a, T, R>
) -> Stream<'a, T> where
T: Clone + FromPrimitive + ToPrimitive,
R: Sub<Output = R> + ToPrimitive + Clone + 'static,
impl<'a> Stream<'a, bool>
[src]
impl<'a> Stream<'a, bool>
[src]Trait Implementations
impl<'a, T2: 'a> StreamExt<'a, T2> for Stream<'a, T2>
[src]
impl<'a, T2: 'a> StreamExt<'a, T2> for Stream<'a, T2>
[src]fn unique(self) -> Stream<'a, T2>
[src]
fn rc(self) -> StreamRc<'a, T2> where
T2: Clone,
[src]
T2: Clone,
fn on_value<'b, F: FnMut(T) + 'b>(self, f: F) -> Stream<'b, T> where
T: Clone + 'a,
'a: 'b,
Self: Sized,
[src]
T: Clone + 'a,
'a: 'b,
Self: Sized,
fn map<'b, T3, F>(self, f: F) -> Stream<'b, T3> where
T: 'a,
T3: 'b,
F: FnMut(T) -> T3 + 'b,
'a: 'b,
Self: Sized,
[src]
T: 'a,
T3: 'b,
F: FnMut(T) -> T3 + '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,
[src]
T: 'a,
'a: 'b,
Self: Sized,
fn filter_by<'b, 'c>(self, p: Property<'b, bool>) -> Stream<'c, T> where
T: 'a,
'a: 'b,
'b: 'c,
Self: Sized,
[src]
T: 'a,
'a: 'b,
'b: 'c,
Self: Sized,
fn partition<'b, F>(self, f: F) -> (Stream<'b, T>, Stream<'b, T>) where
F: FnMut(&T) -> bool + 'b,
'a: 'b,
Self: Sized,
T: 'a,
[src]
F: FnMut(&T) -> bool + 'b,
'a: 'b,
Self: Sized,
T: 'a,
fn filter_map<'b, T3: 'b, F: FnMut(T) -> Option<T3> + 'b>(
self,
f: F
) -> Stream<'b, T3> where
T: 'a,
'a: 'b,
Self: Sized,
[src]
self,
f: F
) -> Stream<'b, T3> where
T: 'a,
'a: 'b,
Self: Sized,
fn partition_map<'b, F, L: 'b, R: 'b>(
self,
f: F
) -> (Stream<'b, L>, Stream<'b, R>) where
F: FnMut(T) -> Either<L, R> + 'b,
'a: 'b,
Self: Sized,
T: 'a,
[src]
self,
f: F
) -> (Stream<'b, L>, Stream<'b, R>) where
F: FnMut(T) -> Either<L, R> + 'b,
'a: 'b,
Self: Sized,
T: 'a,
fn flat_map<'b, T3: 'b, F: FnMut(T) -> Stream<'b, T3> + 'b>(
self,
f: F
) -> Stream<'b, T3> where
T: 'a,
T3: Clone,
'a: 'b,
Self: Sized,
[src]
self,
f: F
) -> Stream<'b, T3> where
T: 'a,
T3: Clone,
'a: 'b,
Self: Sized,
fn take<'b>(self, take: usize) -> Stream<'b, T> where
T: 'a,
'a: 'b,
Self: Sized,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
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,
[src]
T: 'a,
'a: 'b,
Self: Sized,
fn fold<'b, T3: 'b, F: FnMut(T3, T) -> T3 + 'b>(
self,
initial: T3,
f: F
) -> Stream<'b, T3> where
T: 'a,
'a: 'b,
T3: Clone,
Self: Sized,
[src]
self,
initial: T3,
f: F
) -> Stream<'b, T3> where
T: 'a,
'a: 'b,
T3: Clone,
Self: Sized,
fn scan<'b, T2: 'b, T3: 'b, F: FnMut(&mut T2, T) -> Option<T3> + 'b>(
self,
initial: T2,
f: F
) -> Stream<'b, T3> where
T: 'a,
'a: 'b,
Self: Sized,
[src]
self,
initial: T2,
f: F
) -> Stream<'b, T3> where
T: 'a,
'a: 'b,
Self: Sized,
fn dedup<'b>(self) -> Stream<'b, T> where
T: Clone + 'a + PartialEq,
'a: 'b,
Self: Sized,
[src]
T: Clone + '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,
[src]
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 + Clone,
'a: 'b,
Self: Sized,
[src]
T: 'a + PartialEq + Clone,
'a: 'b,
Self: Sized,
fn delay<'b>(self, delay: usize) -> Stream<'b, T> where
T: 'a + PartialEq,
'a: 'b,
Self: Sized,
[src]
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,
[src]
T: 'b,
'a: 'b,
F: Fn(&T) + 'b,
Self: Sized,
fn once<'b, T2>(self, once: T2) -> Stream<'b, T2> where
T: 'a,
T2: 'b,
'a: 'b,
Self: Sized,
[src]
T: 'a,
T2: 'b,
'a: 'b,
Self: Sized,
fn merge<'b, 'c, S: StreamExt<'b, T>>(self, other: S) -> Stream<'c, T> where
T: Clone + 'c,
'a: 'c,
'b: 'c,
Self: Sized,
[src]
T: Clone + 'c,
'a: 'c,
'b: 'c,
Self: Sized,
fn throttle<'c>(self, fps: f32) -> Stream<'c, T> where
T: 'a,
'a: 'c,
Self: Sized,
[src]
T: 'a,
'a: 'c,
Self: Sized,
fn benchmark<'b, 'c, F: 'b, S: StreamExt<'b, F>>(
self,
frame_stream: S
) -> (Stream<'c, T>, Stream<'c, Duration>) where
T: Clone + 'a,
'a: 'c,
'b: 'c,
Self: Sized,
[src]
self,
frame_stream: S
) -> (Stream<'c, T>, Stream<'c, Duration>) where
T: Clone + 'a,
'a: 'c,
'b: 'c,
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,
[src]
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,
[src]
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,
[src]
T: 'a,
'a: 'b,
Self: Sized,
fn until<'b, 'c, T2: 'b, S: StreamExt<'b, T2>>(
self,
until: S
) -> Stream<'c, bool> where
Self: Sized,
T: 'a,
'a: 'c,
'b: 'c,
[src]
self,
until: S
) -> Stream<'c, bool> where
Self: Sized,
T: 'a,
'a: 'c,
'b: 'c,
fn try_iter<'b>(self) -> TryIter<'b, T>ⓘ where
Self: Sized + 'a,
T: 'a,
'a: 'b,
[src]
Self: Sized + 'a,
T: 'a,
'a: 'b,
fn to_parameter(self, initial: T) -> Parameter<'a, T> where
Self: Sized + 'a,
T: 'a,
[src]
Self: Sized + 'a,
T: 'a,
fn try_iter_last_frame<'b, S>(self, last_frame: S) -> TryIterLastFrame<'b, T>ⓘNotable traits for TryIterLastFrame<'a, T>
impl<'a, T> Iterator for TryIterLastFrame<'a, T> type Item = T;
where
Self: Sized + 'a,
T: 'a,
'a: 'b,
S: StreamExt<'a, ()> + 'a,
[src]
Notable traits for TryIterLastFrame<'a, T>
impl<'a, T> Iterator for TryIterLastFrame<'a, T> type Item = T;
Self: Sized + 'a,
T: 'a,
'a: 'b,
S: StreamExt<'a, ()> + 'a,
fn to_box(self) -> Box<dyn StreamExt<'a, T> + 'a> where
Self: Sized + 'a,
[src]
Self: Sized + 'a,
fn to_property<'b>(self, initial: T) -> Property<'a, T> where
T: Clone + 'a,
Self: Sized + Into<StreamRc<'a, T>>,
[src]
T: Clone + 'a,
Self: Sized + Into<StreamRc<'a, T>>,
fn to_property_last_value<'b>(self, initial: T) -> PropertyLastValue<'a, T> where
T: Clone + 'a,
Self: Sized + Into<StreamRc<'a, T>>,
[src]
T: Clone + 'a,
Self: Sized + Into<StreamRc<'a, T>>,
fn collect<'b>(self, samples: usize) -> Property<'b, Vec<T>> where
T: Clone + 'a,
'a: 'b,
Self: Sized,
[src]
T: Clone + 'a,
'a: 'b,
Self: Sized,
Auto Trait Implementations
impl<'a, T2> !RefUnwindSafe for Stream<'a, T2>
impl<'a, T2> !Send for Stream<'a, T2>
impl<'a, T2> !Sync for Stream<'a, T2>
impl<'a, T2> Unpin for Stream<'a, T2> where
T2: Unpin,
T2: Unpin,