Struct dvcompute::simulation::observable::ObservableBox

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

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 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.