Trait Observable 

pub trait Observable<Item, Err>:
    Stream<Item = Result<Item, Err>>
    + ConditionallySendSync
    + Sized
where
    Item: ConditionallySendSync,
    Err: ConditionallySendSync,
{
    // Provided method
    fn pipe(self, into: FluxChannel<Item, Err>) -> FluxPipe<Item, Err, Self> { ... }
}

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

Provided Methods

fn pipe(self, into: FluxChannel<Item, Err>) -> FluxPipe<Item, Err, Self>

Pipe one [Flux] into another.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

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

where Item: ConditionallySendSync, Err: ConditionallySendSync,

impl<Item, Err> Observable<Item, Err> for FluxReceiver<Item, Err>

where Item: ConditionallySendSync, Err: ConditionallySendSync,