Trait futures_concurrency::concurrent_stream::FromConcurrentStream

pub trait FromConcurrentStream<A>: Sized {
    // Required method
    async fn from_concurrent_stream<T>(iter: T) -> Self
       where T: IntoConcurrentStream<Item = A>;
}

Conversion from a ConcurrentStream

Required Methods

async fn from_concurrent_stream<T>(iter: T) -> Self

where T: IntoConcurrentStream<Item = A>,

Creates a value from a concurrent iterator.

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl<T> FromConcurrentStream<T> for Vec<T>

async fn from_concurrent_stream<S>(iter: S) -> Self

where S: IntoConcurrentStream<Item = T>,

Implementors