Struct openiap_client::ClientInner

pub struct ClientInner {
    pub client: FlowServiceClient<Channel>,
    pub signedin: bool,
    pub user: Option<User>,
    pub connected: bool,
    pub stream_tx: Sender<Envelope>,
    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, Box<dyn Fn(QueueEvent) + Send + Sync>>>>,
}

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

Fields

client: FlowServiceClient<Channel>

The grpc client.//!

signedin: bool

Are we signed in?

user: Option<User>

The signed in user.

connected: bool

Are we connected?

stream_tx: Sender<Envelope>

The stream sender.

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, Box<dyn Fn(QueueEvent) + Send + Sync>>>>

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

Trait Implementations

impl Clone for ClientInner

fn clone(&self) -> ClientInner

Returns a copy 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.