Trait wick_packet::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> { ... }
}

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.

Object Safety

This trait is not object safe.

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,