Trait StreamTrait 

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

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

Stream query results

Required Associated Types

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

Create a stream for the QueryResult

Required Methods

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

Execute a Statement 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".

Implementors

impl StreamTrait for DatabaseConnection

type Stream<'a> = QueryStream

impl StreamTrait for DatabaseTransaction

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