Trait sea_orm::query::StreamTrait

pub trait StreamTrait<'a>: Send + Sync {
    type Stream: Stream<Item = Result<QueryResult, DbErr>> + Send;

    fn stream(
        &'a self,
        stmt: Statement
    ) -> Pin<Box<dyn Future<Output = Result<Self::Stream, DbErr>> + Send + 'a>>;
}

Stream query results

Required Associated Types

type Stream: Stream<Item = Result<QueryResult, DbErr>> + Send

Create a stream for the QueryResult

Required Methods

fn stream(
    &'a self,
    stmt: Statement
) -> Pin<Box<dyn Future<Output = Result<Self::Stream, DbErr>> + Send + 'a>>

Execute a Statement and return a stream of results

Implementors

impl<'a> StreamTrait<'a> for DatabaseConnection

type Stream = QueryStream

impl<'a> StreamTrait<'a> for DatabaseTransaction

type Stream = TransactionStream<'a>