Struct Worker 

pub struct Worker {
    rx: Receiver<Command>,
    shared: Arc<Inner>,
    connection_state_store: Store,
    desired_state: ConnectionState,
    connect_task: Option<ConnectTaskHandle>,
}

Fields

rx: Receiver<Command>

shared: Arc<Inner>

connection_state_store: Store

desired_state: ConnectionState

connect_task: Option<ConnectTaskHandle>

Implementations

impl Worker

pub(crate) fn new( shared: Arc<Inner>, rx: Receiver<Command>, connection_state_store: Store, ) -> Self

pub(crate) fn spawn(self) -> JoinHandle<()>

async fn run(self)

async fn add_subscription(&mut self, template: SubscriptionTemplate)

fn start_connect(&mut self)

async fn disconnect(&mut self)