wick_packet

Trait Observable

Source 
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> { ... }
}
Expand description

The wasmrs-rx implementation of an Rx Observable trait

Provided Methods§

Source

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", so this trait is not object safe.

Implementors§

Source§

impl<Item, Err> Observable<Item, Err> for FluxChannel<Item, Err>
where Item: ConditionallySendSync, Err: ConditionallySendSync,

Source§

impl<Item, Err> Observable<Item, Err> for FluxReceiver<Item, Err>
where Item: ConditionallySendSync, Err: ConditionallySendSync,