Enum ClientBackend 

pub(crate) enum ClientBackend {
    Multiplexed {
        message_dispatcher: MessageDispatcher,
        subscriptions: Arc<Subscriptions>,
        send_chan: (Sender<Value>, Receiver<Value>),
    },
    QuicStream {
        quic_conn: Arc<QuicConn>,
        subscriptions: Arc<Subscriptions>,
        unsub_chans: Mutex<HashMap<SubscriptionID, Sender<Value>>>,
    },
    Http {
        http_backend: Box<HttpClientBackend>,
        subscriptions: Arc<Subscriptions>,
    },
}

Variants

Multiplexed

One persistent message connection used by many concurrent calls and subscriptions. Each request is tagged with a unique id; the reader task multiplexes responses back to the right caller. Used for TCP, TLS, WS, WSS, and Unix.

Fields

message_dispatcher: MessageDispatcher

subscriptions: Arc<Subscriptions>

send_chan: (Sender<Value>, Receiver<Value>)

QuicStream

Fields

quic_conn: Arc<QuicConn>

subscriptions: Arc<Subscriptions>

unsub_chans: Mutex<HashMap<SubscriptionID, Sender<Value>>>

Per-subscription unsubscribe signal: send the unsubscribe JSON; the reader task forwards it and exits.

Http

Fields

http_backend: Box<HttpClientBackend>

subscriptions: Arc<Subscriptions>