Trait 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.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so 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>,

impl<T, E> FromConcurrentStream<Result<T, E>> for Result<Vec<T>, E>

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

where S: IntoConcurrentStream<Item = Result<T, E>>,

Implementors