Skip to main content

StreamQueryExecutor

Trait StreamQueryExecutor 

Source
pub trait StreamQueryExecutor: DataServiceExecutor {
    // Required method
    fn query_stream(
        &self,
        request: QueryRequest,
        chunk_size: usize,
    ) -> impl Future<Output = Result<Vec<StreamChunk>, Self::Error>> + Send;
}
Expand description

Streaming query executor. Returns rows in chunks rather than all at once.

Required Methods§

Source

fn query_stream( &self, request: QueryRequest, chunk_size: usize, ) -> impl Future<Output = Result<Vec<StreamChunk>, Self::Error>> + Send

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§