Searched refs:InternalCommand (Results 1 – 1 of 1) sorted by relevance
48 enum InternalCommand { enum283 let (event_tx, mut event_rx) = mpsc::unbounded_channel::<InternalCommand>(); in worker_thread()308 event_tx.send(InternalCommand::MaybeWrite{connection_id})?; in worker_thread()356 event_tx.send(InternalCommand::MaybeWrite{connection_id})?; in worker_thread()374 event_tx.send(InternalCommand::MaybeWrite{connection_id})?; in worker_thread()384 InternalCommand::MaybeWrite {connection_id} => { in worker_thread()417 … event_tx.send(InternalCommand::MaybeWrite { connection_id: client.connection_id().clone() })?; in worker_thread()