async fn subscribe_to_streams<C>(
        &self,
        streams: Vec<String>,
        on_event: C,
        keep_running: &AtomicBool,
    ) where
        C: FnMut(WebsocketEvent) -> Result<(), binance::errors::Error>,
    {
        let mut websocket_connector: WebSockets<'_, WebsocketEvent> = WebSockets::new(on_event);
        websocket_connector.connect_multiple(streams).await.unwrap(); // TODO: handle result
        if let Err(e) = websocket_connector.event_loop(keep_running).await {
            error!(" {}: error on event loop: {}", self.cfg.name, e); // TODO: handle error
        }
        websocket_connector.disconnect().await.unwrap() // TODO: handle unwrap
    }

error[E0599]: no method named `sub` found for enum `std::option::Option` in the current scope
   --> rust/.cargo/registry/src/github.com-1ecc6299db9ec823/binance-rs-async-1.1.10/src/wallet.rs:175:66
    |
175 |         let mut current_period_start: DateTime<Utc> = start_from.sub(interval_duration);
    |                                                                  ^^^ method not found in `std::option::Option<DateTime<Utc>>`
    |
note: the method `sub` exists on the type `DateTime<Utc>`
   --> rust/.rustup/toolchains/nightly-x86_64-unknown-linux-gnu/lib/rustlib/src/rust/library/core/src/ops/arith.rs:221:5
    |
221 |     fn sub(self, rhs: Rhs) -> Self::Output;
    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
help: consider using `Option::expect` to unwrap the `DateTime<Utc>` value, panicking if the value is an `Option::None`
    |
175 |         let mut current_period_start: DateTime<Utc> = start_from.expect("REASON").sub(interval_duration);
    |                                                                 +++++++++++++++++

error[E0308]: mismatched types
   --> rust/.cargo/registry/src/github.com-1ecc6299db9ec823/binance-rs-async-1.1.10/src/wallet.rs:184:48
    |
184 |             let records = self.deposit_history(&query).await?;
    |                                --------------- ^^^^^^ expected struct `rest_model::DepositHistoryQuery`, found `&rest_model::DepositHistoryQuery`
    |                                |
    |                                arguments to this function are incorrect
    |
note: associated function defined here
   --> rust/.cargo/registry/src/github.com-1ecc6299db9ec823/binance-rs-async-1.1.10/src/wallet.rs:148:18
    |
148 |     pub async fn deposit_history(&self, query: DepositHistoryQuery) -> Result<Vec<DepositRecord>> {
    |                  ^^^^^^^^^^^^^^^ -----  --------------------------
help: consider removing the borrow
    |
184 -             let records = self.deposit_history(&query).await?;
184 +             let records = self.deposit_history(query).await?;
    |

error[E0368]: binary assignment operation `-=` cannot be applied to type `DateTime<Utc>`
   --> rust/.cargo/registry/src/github.com-1ecc6299db9ec823/binance-rs-async-1.1.10/src/wallet.rs:195:13
    |
195 |             current_period_start -= interval_duration;
    |             --------------------^^^^^^^^^^^^^^^^^^^^^
    |             |
    |             cannot use `-=` on type `DateTime<Utc>`

error[E0368]: binary assignment operation `-=` cannot be applied to type `DateTime<Utc>`
   --> rust/.cargo/registry/src/github.com-1ecc6299db9ec823/binance-rs-async-1.1.10/src/wallet.rs:196:13
    |
196 |             current_period_end -= interval_duration;
    |             ------------------^^^^^^^^^^^^^^^^^^^^^
    |             |
    |             cannot use `-=` on type `DateTime<Utc>`

error[E0599]: no method named `sub` found for enum `std::option::Option` in the current scope
   --> rust/.cargo/registry/src/github.com-1ecc6299db9ec823/binance-rs-async-1.1.10/src/wallet.rs:241:66
    |
241 |         let mut current_period_start: DateTime<Utc> = start_from.sub(interval_duration);
    |                                                                  ^^^ method not found in `std::option::Option<DateTime<Utc>>`
    |
note: the method `sub` exists on the type `DateTime<Utc>`
   --> rust/.rustup/toolchains/nightly-x86_64-unknown-linux-gnu/lib/rustlib/src/rust/library/core/src/ops/arith.rs:221:5
    |
221 |     fn sub(self, rhs: Rhs) -> Self::Output;
    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
help: consider using `Option::expect` to unwrap the `DateTime<Utc>` value, panicking if the value is an `Option::None`
    |
241 |         let mut current_period_start: DateTime<Utc> = start_from.expect("REASON").sub(interval_duration);
    |                                                                 +++++++++++++++++

error[E0308]: mismatched types
   --> rust/.cargo/registry/src/github.com-1ecc6299db9ec823/binance-rs-async-1.1.10/src/wallet.rs:250:49
    |
250 |             let records = self.withdraw_history(&query).await?;
    |                                ---------------- ^^^^^^ expected struct `rest_model::WithdrawalHistoryQuery`, found `&rest_model::WithdrawalHistoryQuery`
    |                                |
    |                                arguments to this function are incorrect
    |
note: associated function defined here
   --> rust/.cargo/registry/src/github.com-1ecc6299db9ec823/binance-rs-async-1.1.10/src/wallet.rs:212:18
    |
212 |     pub async fn withdraw_history(&self, query: WithdrawalHistoryQuery) -> Result<Vec<WithdrawalRecord>> {
    |                  ^^^^^^^^^^^^^^^^ -----  -----------------------------
help: consider removing the borrow
    |
250 -             let records = self.withdraw_history(&query).await?;
250 +             let records = self.withdraw_history(query).await?;
    |

error[E0368]: binary assignment operation `-=` cannot be applied to type `DateTime<Utc>`
   --> rust/.cargo/registry/src/github.com-1ecc6299db9ec823/binance-rs-async-1.1.10/src/wallet.rs:261:13
    |
261 |             current_period_start -= interval_duration;
    |             --------------------^^^^^^^^^^^^^^^^^^^^^
    |             |
    |             cannot use `-=` on type `DateTime<Utc>`

error[E0368]: binary assignment operation `-=` cannot be applied to type `DateTime<Utc>`
   --> rust/.cargo/registry/src/github.com-1ecc6299db9ec823/binance-rs-async-1.1.10/src/wallet.rs:262:13
    |
262 |             current_period_end -= interval_duration;
    |             ------------------^^^^^^^^^^^^^^^^^^^^^
    |             |
    |             cannot use `-=` on type `DateTime<Utc>`

handler: Box<dyn FnMut(WE) -> Result<()> + 'a>

use tokio::runtime::Runtime;
if let WebsocketEvent::OrderUpdate(trade) = event {
    let rt = Runtime::new().unwrap();
    rt.block_on(async { do_sth(event).await })
};

let account: Account = Binance::new_with_env(&Config::testnet());
    let limit_buy = OrderRequest {
            symbol: "BTCUSDT".to_string(),
            quantity: Some(0.01),
            price: Some(40000.0),
            order_type: OrderType::Limit,
            side: OrderSide::Buy,
            time_in_force: Some(TimeInForce::FOK),
            ..OrderRequest::default()
        };
    match account.place_order(limit_buy).await {
        Ok(answer) => println!("{:?}", answer),
        Err(e) => println!("Error: {e}"),
    }

Error: code: -1022, msg: Signature for this request is not valid.

`dyn FnMut(binance::ws_model::WebsocketEvent) -> Result<(), binance::errors::Error>` cannot be sent between threads safely
the trait `Send` is not implemented for `dyn FnMut(binance::ws_model::WebsocketEvent) -> Result<(), binance::errors::Error>`

Err(ReqError(reqwest::Error { kind: Decode, source: Error("unknown variant `CURRENT_QUARTER DELIVERING`, expected one of `PERPETUAL`, `CURRENT_MONTH`, `NEXT_MONTH`, `CURRENT_QUARTER`, `NEXT_QUARTER`, ``", line: 1, column: 246483) }))

async fn book_ticker() {
    let keep_running = AtomicBool::new(true);
    let agg_trade: String = "btcusdt@bookTicker".to_string();

    let mut web_socket: WebSockets<'_, WebsocketEvent> =
        WebSockets::new(|events: WebsocketEvent| {
            if let WebsocketEvent::BookTicker(tick_event) = events {
                println!("{:?}", tick_event)
            }
    
            Ok(())
        });

    web_socket.connect(&agg_trade).await.unwrap(); // check error
    if let Err(e) = web_socket.event_loop(&keep_running).await {
        println!("Error: {}", e);
    }
    web_socket.disconnect().await.unwrap();
    println!("disconnected");
}

Error: Json(Error("missing field `maxNumOrders`", line: 1, column: 1381))