async fn handle_ws_op_queue(
    queue: Queue,
    queue_event: EventAsync,
    ws_op_rx: Receiver<WSOp>,
    state: Arc<RwLock<BalloonState>>,
    stop_rx: Receiver<()>
) -> Result<Queue, BalloonError>