Struct sodium_rust::sodium::Stream
source · pub struct Stream<A> {
pub impl_: Stream<A>,
}
Fields
impl_: Stream<A>
Implementations
sourceimpl<A: Clone + Trace + Finalize + 'static> Stream<Option<A>>
impl<A: Clone + Trace + Finalize + 'static> Stream<Option<A>>
pub fn filter_option(&self) -> Stream<A>
sourceimpl<A: Clone + Trace + Finalize + 'static> Stream<A>
impl<A: Clone + Trace + Finalize + 'static> Stream<A>
pub fn to_dep(&self) -> Dep
pub fn map<B: Clone + Trace + Finalize + 'static, F: IsLambda1<A, B> + 'static>(
&self,
f: F
) -> Stream<B>
pub fn hold(&self, a: A) -> Cell<A>
pub fn filter<PRED: IsLambda1<A, bool> + 'static>(&self, pred: PRED) -> Stream<A>
pub fn merge<SA: IsStream<A>, FN: Fn(&A, &A) -> A + 'static>(
&self,
sa: SA,
f: FN
) -> Stream<A>
pub fn gate<CA: IsCell<bool>>(&self, ca: CA) -> Stream<A>
pub fn collect_lazy<B, S, F>(&self, init_state: MemoLazy<S>, f: F) -> Stream<B>where
B: Clone + Trace + Finalize + 'static,
S: Clone + Trace + Finalize + 'static,
F: IsLambda2<A, S, (B, S)> + 'static,
pub fn accum_lazy<S, F>(&self, init_state: MemoLazy<S>, f: F) -> Cell<S>where
S: Clone + Trace + Finalize + 'static,
F: IsLambda2<A, S, S> + 'static,
pub fn once(&self) -> Stream<A>
pub fn snapshot<B, CB: IsCell<B>>(&self, cb: CB) -> Stream<B>where
B: Trace + Finalize + Clone + 'static,
pub fn snapshot2<B, C, CB: IsCell<B>, FN: IsLambda2<A, B, C> + 'static>(
&self,
cb: CB,
f: FN
) -> Stream<C>where
B: Trace + Finalize + Clone + 'static,
C: Trace + Finalize + Clone + 'static,
pub fn snapshot3<B, C, D, CB: IsCell<B>, CC: IsCell<C>, FN: IsLambda3<A, B, C, D> + 'static>(
&self,
cb: CB,
cc: CC,
f: FN
) -> Stream<D>where
B: Trace + Finalize + Clone + 'static,
C: Trace + Finalize + Clone + 'static,
D: Trace + Finalize + Clone + 'static,
pub fn snapshot4<B, C, D, E, CB: IsCell<B>, CC: IsCell<C>, CD: IsCell<D>, FN: IsLambda4<A, B, C, D, E> + 'static>(
&self,
cb: CB,
cc: CC,
cd: CD,
f: FN
) -> Stream<E>where
B: Trace + Finalize + Clone + 'static,
C: Trace + Finalize + Clone + 'static,
D: Trace + Finalize + Clone + 'static,
E: Trace + Finalize + Clone + 'static,
pub fn snapshot5<B, C, D, E, F, CB: IsCell<B>, CC: IsCell<C>, CD: IsCell<D>, CE: IsCell<E>, FN: IsLambda5<A, B, C, D, E, F> + 'static>(
&self,
cb: CB,
cc: CC,
cd: CD,
ce: CE,
f: FN
) -> Stream<F>where
B: Trace + Finalize + Clone + 'static,
C: Trace + Finalize + Clone + 'static,
D: Trace + Finalize + Clone + 'static,
E: Trace + Finalize + Clone + 'static,
E: Trace + Finalize + Clone + 'static,
F: Trace + Finalize + Clone + 'static,
pub fn snapshot6<B, C, D, E, F, G, CB: IsCell<B>, CC: IsCell<C>, CD: IsCell<D>, CE: IsCell<E>, CF: IsCell<F>, FN: IsLambda6<A, B, C, D, E, F, G> + 'static>(
&self,
cb: CB,
cc: CC,
cd: CD,
ce: CE,
cf: CF,
f: FN
) -> Stream<G>where
B: Trace + Finalize + Clone + 'static,
C: Trace + Finalize + Clone + 'static,
D: Trace + Finalize + Clone + 'static,
E: Trace + Finalize + Clone + 'static,
E: Trace + Finalize + Clone + 'static,
F: Trace + Finalize + Clone + 'static,
G: Trace + Finalize + Clone + 'static,
pub fn listen<CALLBACK: FnMut(&A) + 'static>(
&self,
callback: CALLBACK
) -> Listener
pub fn listen_weak<CALLBACK: FnMut(&A) + 'static>(
&self,
callback: CALLBACK
) -> Listener
Trait Implementations
sourceimpl<A: Finalize + Trace + Clone + 'static> IsStream<A> for Stream<A>
impl<A: Finalize + Trace + Clone + 'static> IsStream<A> for Stream<A>
fn to_stream(&self) -> Stream<A>
fn map<B: Clone + Trace + Finalize + 'static, F: IsLambda1<A, B> + 'static>(
&self,
f: F
) -> Stream<B>
fn map_to<B: Clone + Trace + Finalize + 'static>(&self, b: &B) -> Stream<B>
fn hold(&self, a: A) -> Cell<A>
fn filter<PRED: IsLambda1<A, bool> + 'static>(&self, pred: PRED) -> Stream<A>
fn merge<SA: IsStream<A>, FN: Fn(&A, &A) -> A + 'static>(
&self,
sa: SA,
f: FN
) -> Stream<A>
fn gate<CA: IsCell<bool>>(&self, ca: CA) -> Stream<A>
fn collect<B, S, F>(&self, init_state: S, f: F) -> Stream<B>where
B: Clone + Trace + Finalize + 'static,
S: Clone + Trace + Finalize + 'static,
F: IsLambda2<A, S, (B, S)> + 'static,
fn collect_lazy<B, S, F>(&self, init_state: MemoLazy<S>, f: F) -> Stream<B>where
B: Clone + Trace + Finalize + 'static,
S: Clone + Trace + Finalize + 'static,
F: IsLambda2<A, S, (B, S)> + 'static,
fn accum<S, F>(&self, init_state: S, f: F) -> Cell<S>where
S: Clone + Trace + Finalize + 'static,
F: IsLambda2<A, S, S> + 'static,
fn accum_lazy<S, F>(&self, init_state: MemoLazy<S>, f: F) -> Cell<S>where
S: Clone + Trace + Finalize + 'static,
F: IsLambda2<A, S, S> + 'static,
fn once(&self) -> Stream<A>
fn or_else<SA: IsStream<A>>(&self, sa: SA) -> Stream<A>
fn snapshot<B, CB: IsCell<B>>(&self, cb: CB) -> Stream<B>where
B: Trace + Finalize + Clone + 'static,
fn snapshot2<B, C, CB: IsCell<B>, FN: IsLambda2<A, B, C> + 'static>(
&self,
cb: CB,
f: FN
) -> Stream<C>where
B: Trace + Finalize + Clone + 'static,
C: Trace + Finalize + Clone + 'static,
fn snapshot3<B, C, D, CB: IsCell<B>, CC: IsCell<C>, FN: IsLambda3<A, B, C, D> + 'static>(
&self,
cb: CB,
cc: CC,
f: FN
) -> Stream<D>where
B: Trace + Finalize + Clone + 'static,
C: Trace + Finalize + Clone + 'static,
D: Trace + Finalize + Clone + 'static,
fn snapshot4<B, C, D, E, CB: IsCell<B>, CC: IsCell<C>, CD: IsCell<D>, FN: IsLambda4<A, B, C, D, E> + 'static>(
&self,
cb: CB,
cc: CC,
cd: CD,
f: FN
) -> Stream<E>where
B: Trace + Finalize + Clone + 'static,
C: Trace + Finalize + Clone + 'static,
D: Trace + Finalize + Clone + 'static,
E: Trace + Finalize + Clone + 'static,
fn snapshot5<B, C, D, E, F, CB: IsCell<B>, CC: IsCell<C>, CD: IsCell<D>, CE: IsCell<E>, FN: IsLambda5<A, B, C, D, E, F> + 'static>(
&self,
cb: CB,
cc: CC,
cd: CD,
ce: CE,
f: FN
) -> Stream<F>where
B: Trace + Finalize + Clone + 'static,
C: Trace + Finalize + Clone + 'static,
D: Trace + Finalize + Clone + 'static,
E: Trace + Finalize + Clone + 'static,
E: Trace + Finalize + Clone + 'static,
F: Trace + Finalize + Clone + 'static,
fn snapshot6<B, C, D, E, F, G, CB: IsCell<B>, CC: IsCell<C>, CD: IsCell<D>, CE: IsCell<E>, CF: IsCell<F>, FN: IsLambda6<A, B, C, D, E, F, G> + 'static>(
&self,
cb: CB,
cc: CC,
cd: CD,
ce: CE,
cf: CF,
f: FN
) -> Stream<G>where
B: Trace + Finalize + Clone + 'static,
C: Trace + Finalize + Clone + 'static,
D: Trace + Finalize + Clone + 'static,
E: Trace + Finalize + Clone + 'static,
E: Trace + Finalize + Clone + 'static,
F: Trace + Finalize + Clone + 'static,
G: Trace + Finalize + Clone + 'static,
fn listen<CALLBACK: FnMut(&A) + 'static>(&self, callback: CALLBACK) -> Listener
fn listen_weak<CALLBACK: FnMut(&A) + 'static>(
&self,
callback: CALLBACK
) -> Listener
Auto Trait Implementations
impl<A> !RefUnwindSafe for Stream<A>
impl<A> !Send for Stream<A>
impl<A> !Sync for Stream<A>
impl<A> Unpin for Stream<A>
impl<A> !UnwindSafe for Stream<A>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more