paulex
01/27/2020, 2:39 PMrepo.add(user.build())
.thenAccept { responseObserver.onNext(it) }
.exceptionally { e -> responseObserver.onError(ApiErrorUtil.handle(e)); null }
.thenApply { responseObserver.onCompleted() }
.toCompletableFuture().get()