Trait StreamTrait 

pub trait StreamTrait {
    type Stream<'a>: Iterator<Item = Result<QueryResult, DbErr>>
       where Self: 'a;

    // Required methods
    fn get_database_backend(&self) -> DbBackend;
    fn stream_raw<'a>(
        &'a self,
        stmt: Statement,
    ) -> Result<Self::Stream<'a>, DbErr>;

    // Provided method
    fn stream<'a, S: StatementBuilder>(
        &'a self,
        stmt: &S,
    ) -> Result<Self::Stream<'a>, DbErr> { ... }
}

Stream query results

Required Associated Types

type Stream<'a>: Iterator<Item = Result<QueryResult, DbErr>> where Self: 'a

Create a stream for the QueryResult

Required Methods

fn get_database_backend(&self) -> DbBackend

Get the database backend for the connection. This depends on feature flags enabled.

fn stream_raw<'a>(&'a self, stmt: Statement) -> Result<Self::Stream<'a>, DbErr>

Execute a Statement and return a stream of results

Provided Methods

fn stream<'a, S: StatementBuilder>( &'a self, stmt: &S, ) -> Result<Self::Stream<'a>, DbErr>

Execute a [QueryStatement] and return a stream of results

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl StreamTrait for DatabaseConnection

type Stream<'a> = QueryStream

impl StreamTrait for DatabaseTransaction

type Stream<'a> = TransactionStream<'a>