Struct ClientInner

pub struct ClientInner {
    pub queries: Arc<Mutex<HashMap<String, Sender<Envelope>>>>,
    pub streams: Arc<Mutex<HashMap<String, Sender<Vec<u8>>>>>,
    pub watches: Arc<Mutex<HashMap<String, Box<dyn Fn(WatchEvent) + Send + Sync>>>>,
    pub queues: Arc<Mutex<HashMap<String, Arc<dyn Fn(Arc<Client>, QueueEvent) -> BoxFuture<'static, Option<String>> + Send + Sync>>>>,
}

The ClientInner struct provides the inner client for the OpenIAP service.

Fields

queries: Arc<Mutex<HashMap<String, Sender<Envelope>>>>

list of queries ( messages sent to server we are waiting on a response for )

streams: Arc<Mutex<HashMap<String, Sender<Vec<u8>>>>>

Active streams the server (or client) has opened

watches: Arc<Mutex<HashMap<String, Box<dyn Fn(WatchEvent) + Send + Sync>>>>

List of active watches ( change streams )

queues: Arc<Mutex<HashMap<String, Arc<dyn Fn(Arc<Client>, QueueEvent) -> BoxFuture<'static, Option<String>> + Send + Sync>>>>

List of active queues ( message queues / mqqt queues or exchanges )

Trait Implementations

impl Clone for ClientInner

fn clone(&self) -> ClientInner

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClientInner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.