pub(crate) async fn test_connect_and_subscribe( rx: &mut UnboundedReceiver<DataEvent>, ) -> Result<()>