Struct Query 

pub struct Query { /* private fields */ }

Handle to an in-flight query.

Dropping the handle implicitly cancels the query.

Implementations

impl Query

pub const fn handle(&self) -> QueryHandle

The underlying proto-layer query handle.

pub fn dropped_answers(&self) -> u64

Number of answers dropped so far because the per-query backlog filled. Monotonic for the life of the query. A non-zero, growing value means the consumer is not keeping up with a burst of answers and some QueryEvent::Answer values were discarded; see that variant for the lossy-stream contract.

pub async fn next(&mut self) -> Option<QueryEvent>

Wait for the next answer or terminal. Returns None once the query has ended (terminal delivered) or the driver task has exited.

Single-consumer: this takes &mut self, so there is at most one in-flight next() future per Query. That is deliberate — the wakeup path assumes one waiter, and it makes the lossy-stream contract on QueryEvent::Answer the only source of gaps.

pub async fn cancel(self) -> Result<(), CancelError>

Explicitly cancel the query. Equivalent to dropping the handle but returns an error if the driver task has already exited.

Trait Implementations

impl Drop for Query

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.