Struct dvcompute::simulation::observable::ObservableBox

pub struct ObservableBox<T> { /* fields omitted */ }

It represents the boxed Observable computation.

Trait Implementations

impl<T> Observable for ObservableBox<T>

type Message = T

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 into_boxed(self) -> ObservableBox<Self::Message> where
    Self: Sized + 'static, 

Convert into a boxed value.

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 delay(self, dt: f64) -> Delay<Self> where
    Self: Sized,
    Self::Message: Clone + 'static, 

Delay the receiving of messages.

fn delayc<U, F>(self, f: F) -> DelayC<Self, U, F> where
    Self: Sized,
    Self::Message: Clone + 'static,
    F: Fn() -> U + 'static,
    U: Event<Item = f64>, 

Delay the receiving of messages by intervals calculated within Event 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.