如何转换未来的产出？

Question

对于东京的未来，如果你想转换组合子因果链中的Error，你可以使用from_err::<NewType>()。我想要相同的功能，但为了impl Future<Item = (), Error = ()>中的Item.

我的一些代码示例：

let mut async_series_client = vec![];
async_series_client.push(Box::new(
    SocketHandler::connect(
        port,
        addr,
        handle,
        tx_wave,
        tx_linear,
        KcpSessionManager::new(&handle2).unwrap(),
    )
    .from_err::<HyxeError>()
    .join(tube)
    .map_err(|mut err| err.printf()),
));

这将返回((),())(附带问题：它是否因为连接而返回 (( 元组？我希望它只返回().我该怎么做？

Answer 1

使用 Future::map .这与Option::map、Result::map和Iterator::map相似：

use futures::{future, Future}; // 0.1.27
fn some_future() -> impl Future<Item = i32, Error = ()> {
    future::ok(42)
}
fn change_item() -> impl Future<Item = String, Error = ()> {
    some_future().map(|i| i.to_string())
}

另请参阅Stream::map 。

---

当async/await语法稳定时，您可能永远不需要再次使用此组合器，因为您可以使用普通方法：

async fn some_future() -> i32 {
    42
}
async fn change_output() -> String {
    some_future().await.to_string()
}

或Result::map：

async fn some_future() -> Result<i32, ()> {
    Ok(42)
}
async fn change_output() -> Result<String, ()> {
    some_future().await.map(|i| i.to_string())
}

但它仍然存在：

use futures::{Future, FutureExt}; // 0.3.0-alpha.16
async fn some_future() -> i32 {
    42
}
fn change_output() -> impl Future<Output = String> {
    some_future().map(|i| i.to_string())
}