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