Struct dvcompute::simulation::observable::FilterC

pub struct FilterC<M, U, F> { /* private fields */ }

The monadic filter for the Observable computation.

Trait Implementations

impl<M: Clone, U: Clone, F: Clone> Clone for FilterC<M, U, F>

fn clone(&self) -> FilterC<M, U, F>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<M, U, F> Observable for FilterC<M, U, F>

where M: Observable, F: Fn(&M::Message) -> U + 'static, U: Event<Item = bool>, M::Message: 'static,

type Message = <M as Observable>::Message

The type of messages to notify in the current modeling time.

fn subscribe<O>(self, observer: O) -> EventBox<DisposableBox>

where O: Observer<Message = Self::Message, Item = ()> + 'static,

Subscribe the observer.

fn map<B, F>(self, f: F) -> Map<Self, B, F>

where Self: Sized, F: Fn(&Self::Message) -> B + 'static, Self::Message: 'static, B: 'static,

Map the current computation using the specified transform.

fn mapc<U, B, F>(self, f: F) -> MapC<Self, U, B, F>

where Self: Sized, F: Fn(&Self::Message) -> U + 'static, U: Event<Item = B>, Self::Message: 'static, B: 'static,

Map the current computation using the specified transform computation.

fn filter<F>(self, f: F) -> Filter<Self, F>

where Self: Sized, F: Fn(&Self::Message) -> bool + 'static, Self::Message: 'static,

Filter the messages.

fn filterc<U, F>(self, f: F) -> FilterC<Self, U, F>

where Self: Sized, F: Fn(&Self::Message) -> U + 'static, U: Event<Item = bool>, Self::Message: 'static,

Filter the messages within computation.

fn merge<U>(self, other: U) -> Merge<Self, U>

where Self: Sized, Self::Message: 'static, U: Observable<Message = Self::Message>,

Merge the current computation with another one within the resulting computation.

fn into_boxed(self) -> ObservableBox<Self::Message>

where Self: Sized + 'static,

Convert into a boxed value.