Struct MessageDispatcher

pub(super) struct MessageDispatcher {
    chans: Mutex<HashMap<u32, Sender<Response>>>,
}

Manages client requests

Fields

chans: Mutex<HashMap<u32, Sender<Response>>>

Implementations

impl MessageDispatcher

pub(super) fn new() -> Self

Creates a new MessageDispatcher

pub(super) async fn register(&self, id: u32) -> Receiver<Response>

Registers a new request with a given ID and returns a Receiver channel to wait for the response.

pub(super) async fn unregister(&self, id: &u32)

Unregisters the request with the provided ID

pub(super) async fn clear(&self)

Clear the registered channels.

pub(super) async fn dispatch(&self, res: Response) -> Result<()>

Dispatches a response to the channel associated with the response’s ID.

If a channel is registered for the response’s ID, the response is sent through that channel. If no channel is found for the ID, returns an error.