2

我正在尝试使用该binance_async库，tokio并向futuresBinance 发出并发订单。（请参阅本问题末尾的注释。）我正在使用
的函数返回一个类型。我面临以下问题，在这两个示例中进行了说明：binance_asyncbinance_async::error::Result<impl futures::future::Future<_, _>>

  1. 假设我正在尝试这样做：
let bn = Binance::with_credential(&api_key, &secret_key);
let fut = bn.limit_sell(&symbol, qty, price);
tokio::spawn(fut.unwrap()); // ERROR
/* Error message:
  error[E0277]: `impl futures::future::Future` is not a future
  --> src/main.rs:23:5
   |
23 |     tokio::spawn(fut.unwrap());
   |     ^^^^^^^^^^^^ `impl futures::future::Future` is not a future
   |
   = help: the trait `futures::Future` is not implemented for `impl 
 futures::future::Future`
*/

这太奇怪了。首先，我在任何地方都找不到futures::Future- only futures::future::Future，它fut.unwrap()实现了。有什么帮助吗？

  1. 好吧，忘记 Tokio，让我们试试这个：
let mut orders : Vec<Result<_>> = Vec::new();  // not std::Result
let fut = bn.limit_sell(&symbol, qty, price);
    
orders.push(fut);

let mut futures = Vec::new(); // I want to unwrap them, to use join_all()
for f in orders.iter() {
    match *f {
        Ok(x) => {
            futures.push(x);
        },
        Err(e) => {}
    }
}

futures::future::join_all(futures).await; // <--- ERROR!
/* Error message (one of 3 similar ones):
    error[E0277]: `impl futures::future::Future` is not a future
    --> src/main.rs:37:5
    |
 37 |     join_all(futures).await; // <--- ERROR!
    |     ^^^^^^^^^^^^^^^^^^^^^^^ `impl futures::future::Future` is not a future
    |
    = help: the trait `futures::Future` is not implemented for `impl 
 futures::future::Future`
    = note: required because of the requirements on the impl of `futures::Future` for 
 `JoinAll<impl futures::future::Future>`
    = note: required by `futures::Future::poll`
*/

同样的错误，同样的问题。

笔记：

  1. 我可能是过度进口。如果导入所有这些库看起来有点矫枉过正，甚至是问题的根源，请告诉我！
  2. 我知道这binance_async是一个维护不足的图书馆。我很可能会完全放弃这种方法，binance转而使用 crate。我只是对这个错误很好奇。
  3. 我的主管说这可能与属性宏有关，但我们俩都只有几个月的 Rust 经验并试图快速完成这项工作，我们无法深入挖掘。

非常感谢 ：）

4

1 回答 1

3

binance_async使用futures 0.1，它与现在使用的标准化不std::future::Future兼容tokio。您可以通过启用以下功能将期货 0.1 期货转换为标准期货compat：

futures = { version = "0.3", features = ["compat"] }

并调用.compat()方法：

use futures::compat::Future01CompatExt;

tokio::spawn(fut.unwrap().compat());

use futures::compat::Future01CompatExt;

orders.push(fut.compat());
futures::future::join_all(futures).await;
于 2021-06-11T18:22:38.830 回答