Trait wick_packet::Flux

pub trait Flux<I, E>: Stream<Item = Result<I, E>> + Unpin + ConditionallySafe { }

A generic trait to wrap over Flux, Mono, and supporting types.

Implementors

impl<I, E, T> Flux<I, E> for Twhere T: Stream<Item = Result<I, E>> + Unpin + ConditionallySafe,