Struct ordered_stream::JoinMultiple

pub struct JoinMultiple<C>(pub C);

Join a collection of OrderedStreams.

This is similar to repeatedly using join() on all the streams in the contained collection. It is not optimized to avoid polling streams that are not ready, so it works best if the number of streams is relatively small.

Tuple Fields

0: C

Trait Implementations

impl<C: Clone> Clone for JoinMultiple<C>

fn clone(&self) -> JoinMultiple<C>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<C: Debug> Debug for JoinMultiple<C>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<C: Default> Default for JoinMultiple<C>

fn default() -> JoinMultiple<C>

Returns the “default value” for a type.

impl<C, S> OrderedStream for JoinMultiple<C> where
    for<'a> &'a mut C: IntoIterator<Item = &'a mut Peekable<S>>,
    S: OrderedStream + Unpin, 

type Ordering = <S as OrderedStream>::Ordering

The type ordered by this stream.

type Data = <S as OrderedStream>::Data

The unordered data carried by this stream

fn poll_next_before(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>,
    before: Option<&S::Ordering>
) -> Poll<PollResult<S::Ordering, S::Data>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if needed, and returning NoneBefore if it is known that the stream will not produce any more values ordered before the given point.

fn position_hint(&self) -> Option<MaybeBorrowed<'_, Self::Ordering>>

The minimum value of the ordering for any future items.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<C> Unpin for JoinMultiple<C>