Trait Observer

pub trait Observer<Item, Err>
where
    Item: ConditionallySendSync,
    Err: ConditionallySendSync,
{
    // Required methods
    fn send_signal(&self, signal: Signal<Item, Err>) -> Result<(), Error>;
    fn is_complete(&self) -> bool;

    // Provided methods
    fn send_result(&self, result: Result<Item, Err>) -> Result<(), Error> { ... }
    fn send(&self, item: Item) -> Result<(), Error> { ... }
    fn error(&self, err: Err) -> Result<(), Error> { ... }
    fn complete(&self) { ... }
}

Re-export of wasmrs_rx traits and core types. The wasmrs-rx implementation of an Rx Observer trait

Required Methods

fn send_signal(&self, signal: Signal<Item, Err>) -> Result<(), Error>

Send a complete Signal

fn is_complete(&self) -> bool

Returns true if the observer has been closed.

Provided Methods

fn send_result(&self, result: Result<Item, Err>) -> Result<(), Error>

Send a Result and have it map to an appropriate Signal variant.

fn send(&self, item: Item) -> Result<(), Error>

Send a successful value.

fn error(&self, err: Err) -> Result<(), Error>

Send an error value.

fn complete(&self)

Mark the Observer as complete.

Implementors

impl<Item, Err> Observer<Item, Err> for FluxChannel<Item, Err>

where Item: ConditionallySendSync, Err: ConditionallySendSync,

impl<Item, Err, F> Observer<Item, Err> for F

where Item: ConditionallySendSync, Err: ConditionallySendSync, F: Fn(Signal<Item, Err>) -> Result<(), Error>,