Skip to main content

execute_stream

Function execute_stream 

Source
pub async fn execute_stream<S: StorageClient + StorageSchemaContextOps + StorageSyncContextOps + StorageOperationContextOps + Clone + Send + Sync + 'static>(
    __arg0: State<AppState<S>>,
    __arg1: Extension<i64>,
    __arg2: Json<StreamQueryRequest>,
) -> Result<Sse<impl Stream<Item = Result<Event, HttpError>> + Send + 'static>, HttpError>
Expand description

Execute the query and stream the results