akka - 我如何在 Akka gRPC 中响应自定义错误

Question

使用 Akka-gRPC 时如何发送错误。我知道responseObserver.Error何时使用本机 gRPC 接口，但在 Akka-gRPC 中找不到最佳方法。

我试过这样做，但是我不确定这是否是一个好方法，而且它并没有提供使用谷歌的好处。超前误差模型

override fun createUser(req: CreateUserRequest?): CompletionStage<User>{
    requireNotNull(req)

    val validations = validator.validate(req.user)

    if (validations.isNotEmpty()) return CompletableFuture.failedStage(GrpcServiceException())

    val user = User.newBuilder().build()
    return CompletableFuture.completedFuture(user)
}

Answer 1

你可以用GrpcServiceException这个：你可以CompletionStage用它失败，或者把它从createUser身体里扔出去。