Struct neo4rs::RowStream

pub struct RowStream { /* private fields */ }

An abstraction over a stream of rows, this is returned as a result of crate::Txn::execute.

A stream needs a running transaction to be consumed.

Implementations

impl RowStream

pub async fn next( &mut self, handle: impl TransactionHandle ) -> Result<Option<Row>>

A call to next() will return a row from an internal buffer if the buffer has any entries, if the buffer is empty and the server has more rows left to consume, then a new batch of rows are fetched from the server (using the fetch_size value configured see crate::ConfigBuilder::fetch_size)

pub fn into_stream( self, handle: impl TransactionHandle ) -> impl TryStream<Ok = Row, Error = Error>

Turns this RowStream into a futures::stream::TryStream where every element is a crate::row::Row.

pub fn into_stream_as<T: DeserializeOwned>( self, handle: impl TransactionHandle ) -> impl TryStream<Ok = T, Error = Error>

Turns this RowStream into a futures::stream::TryStream where every row is converted into a T by calling crate::row::Row::to.

pub fn column_into_stream<'db, T: DeserializeOwned + 'db>( self, handle: impl TransactionHandle + 'db, column: &'db str ) -> impl TryStream<Ok = T, Error = Error> + 'db

Turns this RowStream into a futures::stream::TryStream where the value at the given column is converted into a T by calling crate::row::Row::get.