Struct Query 

pub struct Query { /* private fields */ }

Handle to an in-flight query.

Dropping the handle implicitly cancels the query: the driver task removes the proto state machine on its next loop iteration so no further transmits fire against it.

Implementations

impl Query

pub const fn handle(&self) -> QueryHandle

The underlying proto-layer QueryHandle for this query.

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

Wait for the next answer or terminal. Returns None once the terminal has been delivered (single-consumer; subsequent calls report end-of-stream) or the driver has dropped the query entry.

Borrow discipline: every interaction with inner.state is confined to a short synchronous scope; the only .await (notify.listen()) runs after the borrow is dropped at the closing } of the scope.

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.