Struct ClientDispatcher 

pub struct ClientDispatcher<T: Transport> { /* private fields */ }

A dispatcher for a client endpoint.

A client dispatcher receives all of the incoming messages and dispatches them to the client handler and two-way futures. It acts as the message pump for the client.

The dispatcher must be actively polled to receive events and two-way message responses. If the dispatcher is not run concurrently, then events will not be received and two-way message futures will not receive their responses.

Implementations

impl<T: Transport> ClientDispatcher<T>

pub fn new(transport: T) -> Self

Creates a new client from a transport.

pub fn client(&self) -> Client<T>

Returns a client for the dispatcher.

When the last Client is dropped, the dispatcher will be stopped.

pub async fn run<H>(self, handler: H) -> Result<H, ProtocolError<T::Error>>

where H: ClientHandler<T>,

Runs the client with the provided handler.

pub async fn run_client(self) -> Result<(), ProtocolError<T::Error>>

Runs the client with the IgnoreEvents handler.

Trait Implementations

impl<T: Transport> Drop for ClientDispatcher<T>

fn drop(&mut self)

Executes the destructor for this type.