Struct dvcompute_branch::simulation::observable::DelayC
source · [−]pub struct DelayC<M, U, F> { /* private fields */ }
Expand description
Delay the receiving of messages within the Observable
computation.
Trait Implementations
impl<M, U, F> Observable for DelayC<M, U, F> where
M: Observable,
M::Message: Clone + 'static,
F: Fn() -> U + Clone + 'static,
U: Event<Item = f64>,
impl<M, U, F> Observable for DelayC<M, U, F> where
M: Observable,
M::Message: Clone + 'static,
F: Fn() -> U + Clone + 'static,
U: Event<Item = f64>,
Subscribe the observer.
Map the current computation using the specified transform.
Map the current computation using the specified transform computation.
Filter the messages.
Filter the messages within computation.
Delay the receiving of messages.
Delay the receiving of messages by intervals calculated within Event
computation.
Merge the current computation with another one within the resulting computation.
Convert into a boxed value.
Auto Trait Implementations
impl<M, U, F> RefUnwindSafe for DelayC<M, U, F> where
F: RefUnwindSafe,
M: RefUnwindSafe,
U: RefUnwindSafe,
impl<M, U, F> UnwindSafe for DelayC<M, U, F> where
F: UnwindSafe,
M: UnwindSafe,
U: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
type Observable = M
type Observable = M
The target computation.
type Message = <M as Observable>::Message
type Message = <M as Observable>::Message
The type of messages about which the computation notifies.
Convert to the Observable
computation.