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

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

blocking version of PipelineItem::row_affected

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>)