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

Question

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

我试过这样做，但是我不确定这是不是一个好的方法，而且它也没有提供使用google的好处。高级误差模型

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主体中抛出它。