Skip to main content

worker_loop

hopr_transport_session::supervision::worker

Function worker_loop 

Source 
async fn worker_loop(
    supervisor: SessionPixSupervisor,
    cmd_rx: AsyncRx<Array<WorkerCommand>>,
    action_tx: MAsyncTx<Array<SessionPixAction>>,
    gate: Arc<ServiceGate>,
    telemetry: Arc<PixSessionTelemetry>,
    initial_actions: Vec<SessionPixAction>,
)