Struct QueryHandle 

pub struct QueryHandle { /* private fields */ }

A handle to an in-flight query. Returned alongside the row stream so callers can cancel a query without dropping the stream (the stream itself short-circuits to MeshError::QueryCancelled on the next row boundary).

Cheap to clone; the cancel flag is shared.

Implementations

impl QueryHandle

pub fn new(id: QueryId) -> Self

Construct a fresh handle with the given id. The cancel flag starts cleared. Used by both LocalMeshQueryExecutor and the federated executor in super::federated.

pub fn id(&self) -> QueryId

The query’s id.

pub fn cancel(&self)

Signal cancellation. The row stream will surface MeshError::QueryCancelled at its next yield point. Idempotent.

pub fn is_cancelled(&self) -> bool

Whether Self::cancel has been called.

Trait Implementations

impl Clone for QueryHandle

fn clone(&self) -> QueryHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for QueryHandle

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.