Trait laminarmq_io::stream::Stream

pub trait Stream<L: Lender> {
    // Required method
    fn next<'a>(&'a mut self) -> impl Future<Output = Option<L::Item<'a>>> + 'a
       where L: 'a;
}

Required Methods

fn next<'a>(&'a mut self) -> impl Future<Output = Option<L::Item<'a>>> + 'a

where L: 'a,

Object Safety

This trait is not object safe.

Implementors

impl<'x, R, B> Stream<FallibleByteLender<B, <R as FallibleEntity>::Error>> for AsyncReadStreamReadStream<'x, R, B, R::Position, R::Size>

where R: AsyncRead<B>, B: ByteLender,

impl<'x, R, RBL, RS> Stream<FallibleByteLender<BufByteLender<RBL>, BufReaderError<<R as FallibleEntity>::Error>>> for BufReaderStreamReadStream<'x, R, RS, R::Position, R::Size>

where R: StreamRead<RBL>, R::Error: 'static, RBL: ByteLender + 'static, RS: Stream<FallibleByteLender<RBL, R::Error>>,

impl<'x, T> Stream<RefOf<T>> for OnceRef<'x, T>

impl<F> Stream<FallibleByteLender<AwsS3ByteLender, AwsS3Error>> for GetObjectOutputFuture<F>

where F: Future<Output = Result<GetObjectOutput, String>>,

impl<I, S, F, L> Stream<L> for IterChain<I, S, F>

where I: Iterator<Item = S>, S: Stream<L>, L: Lender, F: FnOnce(&()) -> L::Item<'_> + Copy,

impl<RBL, E> Stream<FallibleByteLender<BufByteLender<RBL>, E>> for OnceBufReadResult<E>

where RBL: ByteLender,

impl<S1, S2, L> Stream<L> for Chain<S1, S2>

where S1: Stream<L>, S2: Stream<L>, L: Lender,

impl<S> Stream<OwnedLender<<S as Stream>::Item>> for WrappedStream<S>

where S: FuturesStream + Unpin,

impl<S, F, AL, BL> Stream<BL> for Map<S, F, AL, BL>

where S: Stream<AL>, AL: Lender, BL: Lender, F: for<'x> FnMut(&'x (), AL::Item<'x>) -> BL::Item<'x>,

impl<S, L> Stream<L> for Latch<S>

where S: Stream<L>, L: Lender,

impl<T> Stream<OwnedLender<T>> for Once<T>