我该如何在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主体中抛出。