数据能上图了

src/data_providers/china_futures.rs

@@ -286,6 +286,16 @@ pub fn connect_market_stream(ticker: Ticker) -> impl Stream<Item = Event> {
                                             };
 
                                             orderbook.fetched(&depth_update);
+
+
+                                            let _ = output
+                                                .send(Event::DepthReceived(
+                                                    ticker,
+                                                    t,
+                                                    orderbook.get_depth(),
+                                                    std::mem::take(&mut trades_buffer).into_boxed_slice(),
+                                                ))
+                                                .await;
                                         }
 
                                         StreamData::Trade(_) => {}