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