Trait brontes_types::unordered_buffer_map::BrontesStreamExt

pub trait BrontesStreamExt: StreamExt {
    // Provided method
    fn unordered_buffer_map<F, R>(
        self,
        size: usize,
        map: F,
    ) -> UnorderedBufferMap<Self, F, R>
       where R: Future,
             F: FnMut(Self::Item) -> R,
             Self: Sized { ... }
}

Provided Methods

fn unordered_buffer_map<F, R>( self, size: usize, map: F, ) -> UnorderedBufferMap<Self, F, R>

where R: Future, F: FnMut(Self::Item) -> R, Self: Sized,

Object Safety

This trait is not object safe.

Implementors

impl<T> BrontesStreamExt for T

where T: StreamExt + ?Sized,