wick_component

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

Re-export of wasmrs_rx traits and core types. 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 FluxReceiver<Item, Err>
where Item: ConditionallySendSync, Err: ConditionallySendSync,

Source§

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