async fn handle_ws_data_queue(
    queue: Queue,
    queue_event: EventAsync,
    command_tube: &AsyncTube,
    registered_evt_q: Option<&SendTubeAsync>,
    state: Arc<RwLock<BalloonState>>,
    stop_rx: Receiver<()>
) -> Result<Queue, BalloonError>