Struct dvcompute::simulation::observable::observer::FlatMap

pub struct FlatMap<O, U, F> { /* fields omitted */ }

The monadic bind for the Observer computation.

Trait Implementations

impl<O: Clone, U: Clone, F: Clone> Clone for FlatMap<O, U, F>

fn clone(&self) -> FlatMap<O, U, F>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<O, U, F> Observer for FlatMap<O, U, F> where
    O: Observer,
    U: Observer<Message = O::Message>,
    F: Fn(O::Item) -> U, 

type Message = U::Message

The outer message that the observer reacts to.

type Item = U::Item

The type of the item that the computation returns.

fn flat_map<U, F>(self, f: F) -> FlatMap<Self, U, F> where
    Self: Sized,
    U: Observer<Message = Self::Message>,
    F: Fn(Self::Item) -> U, 

Bind the current computation with its continuation within the resulting computation.

fn map<B, F>(self, f: F) -> Map<Self, B, F> where
    Self: Sized,
    F: Fn(Self::Item) -> B, 

Map the current computation using the specified transform.

fn zip<U>(self, other: U) -> Zip<Self, U> where
    Self: Sized,
    U: Observer<Message = Self::Message>, 

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

fn ap<U, B>(self, other: U) -> Ap<Self, U, B> where
    Self: Sized,
    Self::Item: Fn(U::Item) -> B,
    U: Observer<Message = Self::Message>, 

The function application.

fn into_boxed(self) -> ObserverBox<Self::Message, Self::Item> where
    Self: Sized + 'static, 

Convert into a boxed value.