fix example

price-adapter-raw/examples/binance-service.rs

@@ -0,0 +1,12 @@
+use price_adapter_raw::{BinanceWebsocket, BinanceWebsocketService};
+use std::time::Duration;
+
+#[tokio::main]
+async fn main() {
+    let binance_ws = BinanceWebsocket::new("wss://stream.binance.com:9443");
+    let service = BinanceWebsocketService::new(binance_ws);
+    service.start(&["ethbtc", "btcusdt"]).await.unwrap();
+    tokio::time::sleep(Duration::from_secs(1)).await;
+    let price = service.get_prices(&["btcusdt"]).await;
+    println!("price: {:?}", price);
+}

price-adapter-raw/src/binance_websocket/service.rs

@@ -13,7 +13,7 @@ use crate::{
 pub struct BinanceWebsocketService {
     socket: Arc<Mutex<BinanceWebsocket>>,
     cached_price: Arc<Mutex<HashMap<String, PriceInfo>>>,
-    cancellation_token: Mutex<Option<CancellationToken>>,
+    cancellation_token: Arc<Mutex<Option<CancellationToken>>>,
 }
 
 impl BinanceWebsocketService {
@@ -22,7 +22,7 @@ impl BinanceWebsocketService {
         Self {
             socket: Arc::new(Mutex::new(socket)),
             cached_price: Arc::new(Mutex::new(HashMap::new())),
-            cancellation_token: Mutex::new(None),
+            cancellation_token: Arc::new(Mutex::new(None)),
         }
     }
 

price-adapter-raw/src/error.rs

@@ -29,9 +29,6 @@ pub enum Error {
 
     #[error("Not found: {0}")]
     NotFound(String),
-
-    #[error("cannot use {0} as quote")]
-    ZeroPrice(String),
 }
 
 impl From<std::num::ParseFloatError> for Error {

price-adapter-raw/src/lib.rs

@@ -31,18 +31,16 @@
 //!
 //! #[tokio::main]
 //! async fn main() {
-//!     let mut binance_ws = BinanceWebsocket::new("wss://stream.binance.com:9443", &["ethbtc", "btcusdt"]);
+//!     let mut binance_ws = BinanceWebsocket::new("wss://stream.binance.com:9443");
 //!     binance_ws.connect().await.unwrap();
-//!     while let Some(data) = binance_ws.next().await {
-//!         match data {
-//!             Ok(price) => {
-//!                 println!("price: {}", price);
-//!                 # break;
-//!             }
-//!             Err(e) => {
-//!                 eprintln!("Error: {}", e);
-//!                 break;
-//!             }
+//!     binance_ws.subscribe(&["ethbtc", "btcusdt"]).await;
+//!     let data = binance_ws.next().await.unwrap();
+//!     match data {
+//!         Ok(price) => {
+//!             println!("price: {:?}", price);
+//!         }
+//!         Err(e) => {
+//!             eprintln!("Error: {}", e);
 //!         }
 //!     }
 //! }
@@ -55,10 +53,9 @@
 //!
 //! #[tokio::main]
 //! async fn main() {
-//!     let mut binance_ws = BinanceWebsocket::new("wss://stream.binance.com:9443", &["ethbtc", "btcusdt"]);
-//!
+//!     let mut binance_ws = BinanceWebsocket::new("wss://stream.binance.com:9443");
 //!     let mut service = BinanceWebsocketService::new(binance_ws);
-//!     service.start().await.unwrap();
+//!     service.start(&["ethbtc", "btcusdt"]).await.unwrap();
 //!     tokio::time::sleep(Duration::from_secs(1)).await;
 //!
 //!     let price = service.get_prices(&["btcusdt"]).await;