Trait wick_packet::Observer

pub trait Observer<Item, Err>where
    Item: ConditionallySafe,
    Err: ConditionallySafe,{
    // 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) { ... }
}

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: ConditionallySafe, Err: ConditionallySafe,