Merge pull request yutiansut#1783 from yutiansut/master

#

Author: yutiansut

qapro-rs/examples/factorplayground.rs

@@ -163,5 +163,5 @@ async fn main() {
     }
 
     println!("calc get row time {:#?}", sw.elapsed());
-    acc.to_csv("".to_string());
+    let _  = acc.to_csv("".to_string()).unwrap();
 }

qapro-rs/src/qaprotocol/mifi/qafastkline.rs

@@ -137,10 +137,10 @@ impl QAKlineBase {
             self.init_data(data.clone());
         }
         let new_price = data["close"].as_f64().unwrap();
-        if (self.high < new_price) {
+        if self.high < new_price {
             self.high = new_price;
         }
-        if (self.low > new_price) {
+        if self.low > new_price {
             self.low = new_price;
         }
         self.close = new_price;
@@ -267,10 +267,10 @@ impl QAKlineBase {
     }
 
     pub fn update_from_bar(&mut self, data: BAR) {
-        if (self.high < data.high) {
+        if self.high < data.high {
             self.high = data.high;
         }
-        if (self.low > data.low) {
+        if self.low > data.low {
             self.low = data.low;
         }
         self.close = data.close;

qapro-rs/src/qapubsub/instruct_mq.rs

@@ -1,8 +1,8 @@
 use crate::qaruntime::base::Instruct;
 use crate::qaruntime::qamanagers::monitor_manager::MonitorManager;
 
-use actix::prelude::*;
-use actix::{Actor, Addr, Context, Handler, Recipient};
+
+use actix::{Actor, Addr, Context};
 use amiquip::{
     Channel, Connection, ConsumerMessage, ConsumerOptions, Exchange, ExchangeDeclareOptions,
     ExchangeType, FieldTable, Publish, QueueDeclareOptions, Result,