Struct QueryResponse

pub struct QueryResponse<I, A> { /* private fields */ }

Returned for each new Query. It is used to collect Ack’s as well as responses and to provide those back to a client.

Implementations

impl<I, A> QueryResponse<I, A>

pub fn ack_rx(&self) -> Option<Receiver<Node<I, A>>>

Returns a receiver that can be used to listen for acks. Channel will be closed when the query is finished. This is None, if the query did not specify request_ack.

pub fn response_rx(&self) -> Receiver<NodeResponse<I, A>>

Returns a receiver that can be used to listen for responses. Channel will be closed when the query is finished.

pub async fn finished(&self) -> bool

Returns if the query is finished running

pub async fn close(&self)

Used to close the query, which will close the underlying channels and prevent further deliveries

Trait Implementations

impl<I: Clone, A: Clone> Clone for QueryResponse<I, A>

fn clone(&self) -> QueryResponse<I, A>

Returns a duplicate of the value.

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

Performs copy-assignment from source.