Struct rin::events::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, Inner>(
parent: S,
inner: Rc<UnsafeCell<Inner>>
) -> Stream<'a, T2> where
Inner: 'a + StreamInner<'a, T2> + SinkInner<'a, T1>,
S: StreamExt<'p, T1>,
[src]
parent: S,
inner: Rc<UnsafeCell<Inner>>
) -> Stream<'a, T2> where
Inner: 'a + StreamInner<'a, T2> + SinkInner<'a, T1>,
S: StreamExt<'p, T1>,
pub fn from_remove<T1, S, Inner>(
remove: S,
inner: Rc<UnsafeCell<Inner>>
) -> Stream<'a, T2> where
Inner: 'a + StreamInner<'a, T2> + SinkInner<'a, T1>,
S: 'a + Remove,
[src]
remove: S,
inner: Rc<UnsafeCell<Inner>>
) -> Stream<'a, T2> where
Inner: 'a + StreamInner<'a, T2> + SinkInner<'a, T1>,
S: 'a + Remove,
pub fn new<Inner>(inner: Rc<UnsafeCell<Inner>>) -> Stream<'a, T2> where
Inner: 'a + StreamInner<'a, T2>,
[src]
Inner: 'a + StreamInner<'a, T2>,
pub fn send(&self, t: T2)
[src]
pub fn on_drop(self, value: T2) -> Stream<'a, T2>
[src]
impl<'a, T2> Stream<'a, T2> where
T2: 'a,
[src]
impl<'a, T2> Stream<'a, T2> where
T2: 'a,
[src]impl<'a, T2> Stream<'a, T2> where
T2: 'a + Clone,
[src]
impl<'a, T2> Stream<'a, T2> where
T2: 'a + Clone,
[src]pub fn connect_to_property<'c>(
self,
property: &mut Property<'a, T2>
) -> Stream<'a, T2> where
T2: 'c,
Stream<'a, T2>: Sized,
[src]
self,
property: &mut Property<'a, T2>
) -> Stream<'a, T2> where
T2: 'c,
Stream<'a, T2>: Sized,
pub fn connect_to_property_last_value<'c>(
self,
property: &mut PropertyLastValue<'a, T2>
) -> Stream<'a, T2> where
T2: 'c,
Stream<'a, T2>: Sized,
[src]
self,
property: &mut PropertyLastValue<'a, T2>
) -> Stream<'a, T2> where
T2: 'c,
Stream<'a, T2>: Sized,
pub fn swap_parent<S>(&mut self, parent: S) where
S: StreamExt<'a, T2>,
[src]
S: StreamExt<'a, T2>,
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<R, Output = R> + ToPrimitive + Clone + 'static,
[src]
self,
param: &mut RangedPropertyMut<'a, T, R>
) -> Stream<'a, T> where
T: Clone + FromPrimitive + ToPrimitive,
R: Sub<R, Output = R> + ToPrimitive + Clone + 'static,
impl<'a> Stream<'a, bool>
[src]
impl<'a> Stream<'a, bool>
[src]Trait Implementations
impl<'a, T2> StreamExt<'a, T2> for Stream<'a, T2> where
T2: 'a,
[src]
impl<'a, T2> StreamExt<'a, T2> for Stream<'a, T2> where
T2: 'a,
[src]pub fn unique(self) -> Stream<'a, T2>
[src]
pub fn rc(self) -> StreamRc<'a, T2> where
T2: Clone,
[src]
T2: Clone,
pub fn on_value<'b, F>(self, f: F) -> Stream<'b, T> where
'a: 'b,
T: Clone + 'a,
F: 'b + FnMut(T),
[src]
'a: 'b,
T: Clone + 'a,
F: 'b + FnMut(T),
pub fn map<'b, T3, F>(self, f: F) -> Stream<'b, T3> where
'a: 'b,
T: 'a,
F: FnMut(T) -> T3 + 'b,
T3: 'b,
[src]
'a: 'b,
T: 'a,
F: FnMut(T) -> T3 + 'b,
T3: 'b,
pub fn filter<'b, F>(self, f: F) -> Stream<'b, T> where
'a: 'b,
T: 'a,
F: 'b + FnMut(&T) -> bool,
[src]
'a: 'b,
T: 'a,
F: 'b + FnMut(&T) -> bool,
pub fn filter_by<'b, 'c>(self, p: Property<'b, bool>) -> Stream<'c, T> where
'a: 'b,
'b: 'c,
T: 'a,
[src]
'a: 'b,
'b: 'c,
T: 'a,
pub fn partition<'b, F>(self, f: F) -> (Stream<'b, T>, Stream<'b, T>) where
'a: 'b,
T: 'a,
F: FnMut(&T) -> bool + 'b,
[src]
'a: 'b,
T: 'a,
F: FnMut(&T) -> bool + 'b,
pub fn filter_map<'b, T3, F>(self, f: F) -> Stream<'b, T3> where
'a: 'b,
T: 'a,
F: 'b + FnMut(T) -> Option<T3>,
T3: 'b,
[src]
'a: 'b,
T: 'a,
F: 'b + FnMut(T) -> Option<T3>,
T3: 'b,
pub fn partition_map<'b, F, L, R>(self, f: F) -> (Stream<'b, L>, Stream<'b, R>) where
'a: 'b,
L: 'b,
T: 'a,
F: FnMut(T) -> Either<L, R> + 'b,
R: 'b,
[src]
'a: 'b,
L: 'b,
T: 'a,
F: FnMut(T) -> Either<L, R> + 'b,
R: 'b,
pub fn flat_map<'b, T3, F>(self, f: F) -> Stream<'b, T3> where
'a: 'b,
T: 'a,
F: 'b + FnMut(T) -> Stream<'b, T3>,
T3: 'b + Clone,
[src]
'a: 'b,
T: 'a,
F: 'b + FnMut(T) -> Stream<'b, T3>,
T3: 'b + Clone,
pub fn take<'b>(self, take: usize) -> Stream<'b, T> where
'a: 'b,
T: 'a,
[src]
'a: 'b,
T: 'a,
pub fn take_then<'b>(self, take: usize, then: T) -> Stream<'b, T> where
'a: 'b,
T: 'a,
[src]
'a: 'b,
T: 'a,
pub fn take_while<'b, F>(self, f: F) -> Stream<'b, T> where
'a: 'b,
T: 'a,
F: 'b + FnMut(&T) -> bool,
[src]
'a: 'b,
T: 'a,
F: 'b + FnMut(&T) -> bool,
pub fn take_while_then<'b, F>(self, f: F, then: T) -> Stream<'b, T> where
'a: 'b,
T: 'a,
F: 'b + FnMut(&T) -> bool,
[src]
'a: 'b,
T: 'a,
F: 'b + FnMut(&T) -> bool,
pub fn skip<'b>(self, skip: usize) -> Stream<'b, T> where
'a: 'b,
T: 'a,
[src]
'a: 'b,
T: 'a,
pub fn skip_while<'b, F>(self, f: F) -> Stream<'b, T> where
'a: 'b,
T: 'a,
F: 'b + FnMut(&T) -> bool,
[src]
'a: 'b,
T: 'a,
F: 'b + FnMut(&T) -> bool,
pub fn fold<'b, T3, F>(self, initial: T3, f: F) -> Stream<'b, T3> where
'a: 'b,
T: 'a,
F: 'b + FnMut(T3, T) -> T3,
T3: 'b + Clone,
[src]
'a: 'b,
T: 'a,
F: 'b + FnMut(T3, T) -> T3,
T3: 'b + Clone,
pub fn scan<'b, T2, T3, F>(self, initial: T2, f: F) -> Stream<'b, T3> where
'a: 'b,
T: 'a,
F: 'b + FnMut(&mut T2, T) -> Option<T3>,
T3: 'b,
T2: 'b,
[src]
'a: 'b,
T: 'a,
F: 'b + FnMut(&mut T2, T) -> Option<T3>,
T3: 'b,
T2: 'b,
pub fn dedup<'b>(self) -> Stream<'b, T> where
'a: 'b,
T: Clone + 'a + PartialEq<T>,
[src]
'a: 'b,
T: Clone + 'a + PartialEq<T>,
pub fn dedup_by<'b, F, T2>(self, f: F) -> Stream<'b, T> where
'a: 'b,
T: 'a,
F: Fn(&T) -> T2 + 'b,
T2: PartialEq<T2> + 'b,
[src]
'a: 'b,
T: 'a,
F: Fn(&T) -> T2 + 'b,
T2: PartialEq<T2> + 'b,
pub fn dedup_or<'b>(self, or: Property<'b, bool>) -> Stream<'b, T> where
'a: 'b,
T: 'a + PartialEq<T> + Clone,
[src]
'a: 'b,
T: 'a + PartialEq<T> + Clone,
pub fn delay<'b>(self, delay: usize) -> Stream<'b, T> where
'a: 'b,
T: 'a + PartialEq<T>,
[src]
'a: 'b,
T: 'a + PartialEq<T>,
pub fn inspect<'b, F>(self, inspect: F) -> Stream<'b, T> where
'a: 'b,
T: 'b,
F: Fn(&T) + 'b,
[src]
'a: 'b,
T: 'b,
F: Fn(&T) + 'b,
pub fn once<'b, T2>(self, once: T2) -> Stream<'b, T2> where
'a: 'b,
T: 'a,
T2: 'b,
[src]
'a: 'b,
T: 'a,
T2: 'b,
pub fn merge<'b, 'c, S>(self, other: S) -> Stream<'c, T> where
'a: 'c,
'b: 'c,
T: Clone + 'c,
S: StreamExt<'b, T>,
[src]
'a: 'c,
'b: 'c,
T: Clone + 'c,
S: StreamExt<'b, T>,
pub fn throttle<'c>(self, fps: f32) -> Stream<'c, T> where
'a: 'c,
T: 'a,
[src]
'a: 'c,
T: 'a,
pub fn benchmark<'b, 'c, F, S>(
self,
frame_stream: S
) -> (Stream<'c, T>, Stream<'c, Duration>) where
'a: 'c,
'b: 'c,
T: Clone + 'a,
F: 'b,
S: StreamExt<'b, F>,
[src]
self,
frame_stream: S
) -> (Stream<'c, T>, Stream<'c, Duration>) where
'a: 'c,
'b: 'c,
T: Clone + 'a,
F: 'b,
S: StreamExt<'b, F>,
pub 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]
'a: 'b,
T: 'a + Zero<Output = T> + One<Output = T> + Sub<T, Output = T> + Add<T> + Mul<T> + Clone,
pub fn resolution<'b>(self, resolution: u8) -> Stream<'b, T> where
'a: 'b,
T: 'a + Div<T, Output = T> + Mul<T, Output = T> + Float,
[src]
'a: 'b,
T: 'a + Div<T, Output = T> + Mul<T, Output = T> + Float,
pub fn to_bool<'b>(self) -> Stream<'b, bool> where
'a: 'b,
T: 'a,
[src]
'a: 'b,
T: 'a,
pub fn until<'b, 'c, T2, S>(self, until: S) -> Stream<'c, bool> where
'a: 'c,
'b: 'c,
T: 'a,
S: StreamExt<'b, T2>,
T2: 'b,
[src]
'a: 'c,
'b: 'c,
T: 'a,
S: StreamExt<'b, T2>,
T2: 'b,
pub fn try_iter<'b>(self) -> TryIter<'b, T>ⓘ where
'a: 'b,
Self: 'a,
T: 'a,
[src]
'a: 'b,
Self: 'a,
T: 'a,
pub fn to_parameter(self, initial: T) -> Parameter<'a, T> where
Self: 'a,
T: 'a,
[src]
Self: 'a,
T: 'a,
pub 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
'a: 'b,
Self: 'a,
T: 'a,
S: StreamExt<'a, ()> + 'a,
[src]
self,
last_frame: S
) -> TryIterLastFrame<'b, T>ⓘ
Notable traits for TryIterLastFrame<'a, T>
impl<'a, T> Iterator for TryIterLastFrame<'a, T> type Item = T;
'a: 'b,
Self: 'a,
T: 'a,
S: StreamExt<'a, ()> + 'a,
pub fn to_box(self) -> Box<dyn StreamExt<'a, T> + 'a, Global> where
Self: 'a,
[src]
Self: 'a,
pub fn to_property(self, initial: T) -> Property<'a, T> where
Self: Into<StreamRc<'a, T>>,
T: Clone + 'a,
[src]
Self: Into<StreamRc<'a, T>>,
T: Clone + 'a,
pub fn to_property_last_value(self, initial: T) -> PropertyLastValue<'a, T> where
Self: Into<StreamRc<'a, T>>,
T: Clone + 'a,
[src]
Self: Into<StreamRc<'a, T>>,
T: Clone + 'a,
pub fn collect<'b>(self, samples: usize) -> Property<'b, Vec<T, Global>> where
'a: 'b,
T: Clone + 'a,
[src]
'a: 'b,
T: Clone + 'a,
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,
impl<'a, T2> !UnwindSafe for Stream<'a, T2>
Blanket Implementations
impl<'a, S> Events<'a> for S where
S: StreamExt<'a, Event>,
[src]
impl<'a, S> Events<'a> for S where
S: StreamExt<'a, Event>,
[src]pub fn keys(self) -> Stream<'a, KeyEvent>
[src]
pub fn keys_partition(self) -> (Stream<'a, KeyEvent>, Stream<'a, Event>)
[src]
pub fn mouse(self) -> Stream<'a, MouseEvent>
[src]
pub fn mouse_partition(self) -> (Stream<'a, MouseEvent>, Stream<'a, Event>)
[src]
pub fn window(self) -> Stream<'a, WindowEvent>
[src]
pub fn window_partition(self) -> (Stream<'a, WindowEvent>, Stream<'a, Event>)
[src]
pub fn update(self) -> Stream<'a, f64>
[src]
pub fn update_partition(self) -> (Stream<'a, f64>, Stream<'a, Event>)
[src]
pub fn dropped(self) -> Stream<'a, Vec<PathBuf, Global>>
[src]
pub fn dropped_partition(
self
) -> (Stream<'a, Vec<PathBuf, Global>>, Stream<'a, Event>)
[src]
self
) -> (Stream<'a, Vec<PathBuf, Global>>, Stream<'a, Event>)
pub fn with_viewport(
self,
viewport: Property<'a, Rect<i32>>
) -> Stream<'a, Event>
[src]
self,
viewport: Property<'a, Rect<i32>>
) -> Stream<'a, Event>
impl<'a, S> KeyEvents<'a> for S where
S: StreamExt<'a, KeyEvent>,
[src]
impl<'a, S> KeyEvents<'a> for S where
S: StreamExt<'a, KeyEvent>,
[src]pub fn pressed<K>(self, k: K) -> Stream<'a, Key> where
K: Into<Key>,
[src]
K: Into<Key>,
pub fn pressed_with_mods<K>(
self,
k: K,
modifers: KeyModifiers
) -> Stream<'a, Key> where
K: Into<Key>,
[src]
self,
k: K,
modifers: KeyModifiers
) -> Stream<'a, Key> where
K: Into<Key>,
pub fn released<K>(self, k: K) -> Stream<'a, Key> where
K: Into<Key>,
[src]
K: Into<Key>,
pub fn pressed_any(self) -> Stream<'a, Key>
[src]
pub fn released_any(self) -> Stream<'a, Key>
[src]
pub fn character(self, c: char) -> Stream<'a, char>
[src]
pub fn character_any(self) -> Stream<'a, char>
[src]
pub fn is_pressed<K>(self, k: K) -> Stream<'a, bool> where
K: 'a + Into<Key>,
[src]
K: 'a + Into<Key>,
impl<'a, S> MouseButtonEvents<'a> for S where
S: StreamExt<'a, (Point<f64, U2>, MouseButton)>,
[src]
impl<'a, S> MouseButtonEvents<'a> for S where
S: StreamExt<'a, (Point<f64, U2>, MouseButton)>,
[src]impl<'a, S> MouseEvents<'a> for S where
S: StreamExt<'a, MouseEvent>,
[src]
impl<'a, S> MouseEvents<'a> for S where
S: StreamExt<'a, MouseEvent>,
[src]pub fn pressed(
self,
b: MouseButton
) -> Stream<'a, (Point<f64, U2>, MouseButton)>
[src]
self,
b: MouseButton
) -> Stream<'a, (Point<f64, U2>, MouseButton)>
pub fn released(
self,
b: MouseButton
) -> Stream<'a, (Point<f64, U2>, MouseButton)>
[src]
self,
b: MouseButton
) -> Stream<'a, (Point<f64, U2>, MouseButton)>
pub fn pressed_with_mods(
self,
b: MouseButton,
keymods: KeyModifiers
) -> Stream<'a, (Point<f64, U2>, MouseButton, KeyModifiers)>
[src]
self,
b: MouseButton,
keymods: KeyModifiers
) -> Stream<'a, (Point<f64, U2>, MouseButton, KeyModifiers)>
pub fn released_with_mods(
self,
b: MouseButton,
keymods: KeyModifiers
) -> Stream<'a, (Point<f64, U2>, MouseButton, KeyModifiers)>
[src]
self,
b: MouseButton,
keymods: KeyModifiers
) -> Stream<'a, (Point<f64, U2>, MouseButton, KeyModifiers)>
pub fn pressed_and_mods(
self,
b: MouseButton
) -> Stream<'a, (Point<f64, U2>, MouseButton, KeyModifiers)>
[src]
self,
b: MouseButton
) -> Stream<'a, (Point<f64, U2>, MouseButton, KeyModifiers)>
pub fn released_and_mods(
self,
b: MouseButton
) -> Stream<'a, (Point<f64, U2>, MouseButton, KeyModifiers)>
[src]
self,
b: MouseButton
) -> Stream<'a, (Point<f64, U2>, MouseButton, KeyModifiers)>
pub fn moved(self) -> Stream<'a, Point<f64, U2>>
[src]
pub fn scrolled(
self
) -> Stream<'a, Matrix<f64, U2, U1, <DefaultAllocator as Allocator<f64, U2, U1>>::Buffer>>
[src]
self
) -> Stream<'a, Matrix<f64, U2, U1, <DefaultAllocator as Allocator<f64, U2, U1>>::Buffer>>
pub fn is_pressed(self, b: MouseButton) -> Stream<'a, bool>
[src]
pub fn with_viewport(
self,
viewport: Property<'a, Rect<i32>>
) -> Stream<'a, MouseEvent>
[src]
self,
viewport: Property<'a, Rect<i32>>
) -> Stream<'a, MouseEvent>
impl<SS, SP> SupersetOf<SS> for SP where
SS: SubsetOf<SP>,
[src]
impl<SS, SP> SupersetOf<SS> for SP where
SS: SubsetOf<SP>,
[src]pub fn to_subset(&self) -> Option<SS>
[src]
pub fn is_in_subset(&self) -> bool
[src]
pub fn to_subset_unchecked(&self) -> SS
[src]
pub fn from_subset(element: &SS) -> SP
[src]
impl<SS, SP> SupersetOf<SS> for SP where
SS: SubsetOf<SP>,
[src]
impl<SS, SP> SupersetOf<SS> for SP where
SS: SubsetOf<SP>,
[src]