pub async fn run_stream(
t: &Transport,
index: &str,
query: &Value,
sort: &Value,
limit: Option<usize>,
) -> Result<Vec<DslHit>>Expand description
Open a point-in-time on index and page it fully with search_after.
query is the operator’s filter; sort is normalized to a total order by
appending _shard_doc when absent. The PIT is closed on every exit path,
success or error.