async fn handle_events_queue(
    queue: Queue,
    queue_event: EventAsync,
    state: Arc<RwLock<BalloonState>>,
    interrupt: Interrupt,
    command_tube: &AsyncTube,
    stop_rx: Receiver<()>
) -> Result<Queue, BalloonError>