Struct Requestor 

pub struct Requestor<E, D> { /* private fields */ }

A Requestor stream that dispatches requests to any Replier streams bound to the specified topic.

Requestor streams are synchronous, meaning that they will block the current task while awaiting a response, as opposed to the asynchronous, non-blocking nature of Publisher streams. This makes them ideal for any use-cases relying on the RPC messaging pattern, when a response is expected before resuming the task.

Once constructed, requests can be dispatched by calling and awaiting the request method.

Concurrency

The Requestor type derives the Clone trait, so requests can safely be made concurrently, as the Requestor will implicitly handle routing replies to the correct task.

Implementations

impl<E, D> Requestor<E, D>

where E: MessageEncoder + Send + Unpin, D: MessageDecoder + Send + Unpin,

pub async fn request(&mut self, req: E::Item) -> Result<D::Item>

Dispatches a request and blocks the current task while waiting for a response, or a request timeout.

Errors

Returns Err under the current conditions:

• The request fails to be encoded.
• The encoded request fails to dispatched.
• The request times out.
• The reply fails to be decoded.

Trait Implementations

impl<E: Clone, D: Clone> Clone for Requestor<E, D>

fn clone(&self) -> Requestor<E, D>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E, D> KeepAliveStream for Requestor<E, D>

where E: MessageEncoder + Send + Unpin, D: MessageDecoder + Send + Unpin,

type Headers = RequestorPayload

fn reestablish_connection( connection: Arc<Mutex<ClientConnection>>, headers: Self::Headers, ) -> Pin<Box<dyn Future<Output = Result<BiStream>> + Send>>

Callback that is invoked to attempt to reconnect to the Selium server.

fn on_reconnect(&mut self, stream: BiStream)

Callback that is invoked upon successful reconnection.

fn get_connection(&self) -> Arc<Mutex<ClientConnection>>

Retrieves the shared selium client connection.

fn get_headers(&self) -> Self::Headers

Retrieves the headers used to register the stream with the Selium server.