Trait wick_packet::Observable

pub trait Observable<Item, Err>: Stream<Item = Result<Item, Err>> + ConditionallySafe + Sizedwhere
    Item: ConditionallySafe,
    Err: ConditionallySafe,{
    // 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.

Implementors

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

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