Trait AsyncLendingIterator

Source
pub trait AsyncLendingIterator {
    type Ok<'i>
       where Self: 'i;
    type Err;

    // Required method
    fn try_next(
        &mut self,
    ) -> impl Future<Output = Result<Option<Self::Ok<'_>>, Self::Err>> + Send;

    // Provided method
    fn size_hint(&self) -> (usize, Option<usize>) { ... }
}
Expand description

async streaming iterator with borrowed Item from Self.

Required Associated Types§

Source

type Ok<'i> where Self: 'i

Source

type Err

Required Methods§

Source

fn try_next( &mut self, ) -> impl Future<Output = Result<Option<Self::Ok<'_>>, Self::Err>> + Send

Provided Methods§

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.

Implementors§

Source§

impl AsyncLendingIterator for Driver

Source§

type Ok<'i> = Message where Self: 'i

Source§

type Err = Error

Source§

impl AsyncLendingIterator for CopyOut

Source§

type Ok<'i> = Bytes where Self: 'i

Source§

type Err = Error

Source§

impl AsyncLendingIterator for PipelineItem<'_>

Source§

type Ok<'i> = GenericRow<&'i [Column], &'i mut Vec<Range<usize>>, Typed> where Self: 'i

Source§

type Err = Error

Source§

impl AsyncLendingIterator for RowSimpleStream

Source§

type Ok<'i> = GenericRow<&'i [Column], &'i mut Vec<Range<usize>>, NoTyped> where Self: 'i

Source§

type Err = Error

Source§

impl AsyncLendingIterator for RowStreamOwned

Source§

type Ok<'i> = GenericRow<&'i [Column], &'i mut Vec<Range<usize>>, Typed> where Self: 'i

Source§

type Err = Error

Source§

impl<'a> AsyncLendingIterator for PipelineStream<'a>

Source§

type Ok<'i> = PipelineItem<'i> where Self: 'i

Source§

type Err = Error

Source§

impl<'a> AsyncLendingIterator for RowStream<'a>

Source§

type Ok<'i> = GenericRow<&'i [Column], &'i mut Vec<Range<usize>>, Typed> where Self: 'i

Source§

type Err = Error

Source§

impl<I, F, O> AsyncLendingIterator for MapOk<I, F>
where I: AsyncLendingIterator + Send, F: Fn(I::Ok<'_>) -> O + Send, O: Send,

Source§

type Ok<'i> = O where Self: 'i

Source§

type Err = <I as AsyncLendingIterator>::Err