rust - 是否可以让 Future::and_then 有条件地返回不同的 future ？

Question

<分区>

Answer 1

问题是 map_err returns a struct MapErr , 而 err returns a struct FutureResult .

解决问题的一种方法是像这样统一它们:

let f = if do_i_want_to_get_the_full_page {
    futures::future::ok(())
} else {
    futures::future::err(())
};
f.and_then (|_| { res.into_body().concat2().map_err(|_| ()) })

另一个解决方案是装箱您的返回值:

if do_i_want_to_get_the_full_page {
    Box::<Future<_, _>>::new (res.into_body().concat2().map_err(|_| ()))
} else {
    Box::<Future<_, _>>::new (futures::future::err(()))
}

第三种解决方案是始终返回 MapErr :

if do_i_want_to_get_the_full_page {
    res.into_body().concat2().map_err(|_| ())
} else {
    futures::future::err(()).map_err(|_| ())
}

但是，您会遇到一个问题，因为 client.get(…).and_then(…) 的错误类型必须实现 From<hyper::Error> :

error[E0271]: type mismatch resolving `<futures::AndThen<futures::FutureResult<(), ()>, futures::MapErr<futures::stream::Concat2<hyper::Body>, [closure@src/main.rs:34:70: 34:76]>, [closure@src/main.rs:34:32: 34:77 res:_]> as futures::IntoFuture>::Error == hyper::Error`
  --> src/main.rs:28:18
   |
28 |                 .and_then(|res| {
   |                  ^^^^^^^^ expected (), found struct `hyper::Error`
   |
   = note: expected type `()`
              found type `hyper::Error`

如果你不关心这个错误，你可以在 and_then 之前把它映射掉:

client
    .get(uri)
    .map_err (|_| ())
    .and_then(|res| {
        let f = if do_i_want_to_get_the_full_page {
            futures::future::ok(())
        } else {
            futures::future::err(())
        };
        f.and_then(|_| res.into_body().concat2().map_err(|_| ()))
    }).map(|body| {
        println!("len is {}.", body.len());
    }).map_err(|e| {
        println!("Error: {:?}", e);
    })

playground

或使用实现 From<hyper::Error> 的类型在您调用 futures::future::err 的电话中.