1

我收到以下错误，

error[E0283]: type annotations needed for `warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<impl warp::Filter+std::marker::Copy, impl warp::Filte
r+std::marker::Copy>, impl warp::Filter+std::marker::Copy>, [closure@src/http.rs:12:13: 24:4]>`
  --> src/http.rs:12:4
   |
9  |     let create_user = warp::post()
   |         ----------- consider giving `create_user` the explicit type `warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<impl warp::Filter+std:
:marker::Copy, impl warp::Filter+std::marker::Copy>, impl warp::Filter+std::marker::Copy>, [closure@src/http.rs:12:13: 24:4]>`, with the type parameters specified
...
12 |         .and_then(|user: super::user::User| async move {
   |          ^^^^^^^^ cannot infer type
   |
   = note: cannot satisfy `_: reject::sealed::CombineRejection<Rejection>`

这是我写的。我很困惑这应该是什么样子，

pub async fn users() -> impl Filter<Extract = impl warp::Reply, Error = warp::Rejection> + Clone {
  let create_user = warp::post()
    .and(warp::path::end())
    .and(warp::body::json())
    .and_then(|user: super::user::User| async move {
      match &user.id_user {
        None => {
          if let Ok(u) = user.insert().await {
            Ok(warp::reply::json(&u))
          }
          else {
            Ok(warp::reply::json(&"FOO".to_owned()))
          }
        }
        Some(_) => Ok(warp::reply::json(&"FOO".to_owned())),
      }
    });

  let routes = warp::path("users");
  routes.and(create_user)
}

这应该怎么看，我真的应该使用像这样的显式类型，

warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<impl warp::Filter+std::marker::Copy, impl warp: :Filter+std::marker::Copy>, impl warp::Filter+std::marker::Copy>

为了清楚我在这里想要什么，是一个创建用户端点。

  • 我希望从 JSON 反序列化用户对象
  • 如果反序列化后的用户对象具有 id，我希望能够拒绝请求（HTTP 错误）。我不希望用户能够选择 ID。
  • &user.insert()将在数据库中插入用户对象，并返回一个带有 ID 的新用户对象。
  • 我希望将错误或用户对象返回给用户。

如何理解 Warp 请求的荒谬复杂的类型注释？这真的是必需的，还是我犯了错误？

4

1 回答 1

4

and_then()这里的问题是闭包中异步块的类型推断失败。没有Err()路径可以告诉编译器Error变体是什么，因此推理失败。Result您可以通过在其中一个返回分支上注释完整类型来解决此问题：

Ok::<_, warp::Rejection>(warp::reply::json(&u))

更多参考：

https://users.rust-lang.org/t/async-function-parameter-results-in-type-annotation-error/45379

?以及有关在异步块中使用的类似问题的解决方法：

https://rust-lang.github.io/async-book/07_workarounds/02_err_in_async_blocks.html

于 2021-05-06T07:51:56.020 回答