Skip to main content

run_pipeline_streaming

mii_http::exec

Function run_pipeline_streaming 

Source 
pub async fn run_pipeline_streaming(
    statements: &[Vec<ExecStage>],
    ctx: &ExecContext,
    timeout: Option<Duration>,
) -> Result<StreamingExec, String>