Struct xitca_postgres::pipeline::PipelineItem

pub struct PipelineItem<'a> { /* private fields */ }

streaming item of certain query inside pipeline’s PipelineStream. impl AsyncLendingIterator and can be used to collect Row from item.

Implementations

impl PipelineItem<'_>

pub async fn row_affected(self) -> Result<u64, Error>

collect rows affected by this pipelined query. Row information will be ignored.

Panic

calling this method on an already finished PipelineItem will cause panic. PipelineItem is marked as finished when its AsyncLendingIterator::try_next method returns Option::None

Trait Implementations

impl AsyncLendingIterator for PipelineItem<'_>

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

type Err = Error

async fn try_next(&mut self) -> Result<Option<Self::Ok<'_>>, Self::Err>

fn size_hint(&self) -> (usize, Option<usize>)