Trait tiberius::stmt::ResultStreamExt

pub trait ResultStreamExt<I: BoxableIo>: StateStream {
    fn for_each_row<F>(self, f: F) -> ForEachRow<I, Self, F>
    where
        Self: Sized + StateStream<Item = QueryStream<I>, Error = <QueryStream<I> as Stream>::Error>,
        F: FnMut(<QueryStream<I> as Stream>::Item) -> Result<(), TdsError>;
    fn single(self) -> SingleResultSet<I, Self>
    where
        Self: Sized + StateStream<Item = ExecFuture<I>, Error = <ExecFuture<I> as Future>::Error>;
}

Required Methods

fn for_each_row<F>(self, f: F) -> ForEachRow<I, Self, F> where
    Self: Sized + StateStream<Item = QueryStream<I>, Error = <QueryStream<I> as Stream>::Error>,
    F: FnMut(<QueryStream<I> as Stream>::Item) -> Result<(), TdsError>, 

Only expect 1 result set (e.g. if you're only executing one query) and execute a given closure for the results of the first result set

Panics

This will panic if there is more than 1 resultset

fn single(self) -> SingleResultSet<I, Self> where
    Self: Sized + StateStream<Item = ExecFuture<I>, Error = <ExecFuture<I> as Future>::Error>, 

Expect 1 resultset and unpacks the single underlying ExecFuture

Panics

This will panic if there is more than 1 resultset

Implementors

• impl<'a, I: BoxableIo, R: StmtResult<I>> ResultStreamExt<I> for ResultSetStream<I, R>
• impl<I: BoxableIo, R: StmtResult<I>> ResultStreamExt<I> for StmtStream<I, R>