Проблема с GRPC с потоками Netty Nio ⇐ JAVA

[Anonymous]

Здравствуйте, я сталкиваюсь с некоторыми проблемами. Во время интеграции клиента GRPC для использования NIO NIO для NIO для вызова и обработки GRPC я хочу, чтобы потоки приложений были свободны от отслеживания состояния вызовов GRPC, а затем вызывая обратные вызовы.
public TestClient(String host,int port,boolean isSecure){
this.testClientConfiguration.setAddress(host);
this.testClientConfiguration.setSecure(isSecure);
this.testClientConfiguration.setPort(port);
this.testClientConfiguration.setMaxTimeout(20);
ManagedChannelBuilder channelBuilder = ManagedChannelBuilder.forAddress(host, port);
// check if the TLS is disabled for the client then and use plain text communication on the client
if (!this.testClientConfiguration.isSecure()) {
channelBuilder = channelBuilder.usePlaintext();
}

this.channel = channelBuilder
// use the custom executor service
.executor(testClient.executorService)
.build();

this.asyncStub = TestServiceGrpc.newFutureStub(this.channel)
.withExecutor(testClient.executorService);

/**
* Non Blocking call to the server
*/

public Future asyncCheckBalance(SamplePayload payload) {

return Single.fromFuture(this.asyncStub.withDeadlineAfter(this.testClientConfiguration.getMaxTimeout(), TimeUnit.SECONDS)
.testMethod(payload))
.doOnSuccess((resp) -> {
this.logger.info("Check testMethod got response success {}", resp;
this.logger.debug("Check testMethod got response success {}", resp;
}).doOnError(throwable -> this.logError(throwable, "Check testMethod payload:" + payload))
.toFuture();
}
< /code>
Теперь все становится странно, как только я удаляю методы.java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNKNOWN
concurrentExecutionException
< /code>
Что я могу попытаться исправить это? Моя цель состоит в том, чтобы использовать NIO Netty, чтобы сделать эти вызовы и обратные вызовы, чтобы быть запланированным в потоке приложения (Caller-> Grpc-> Netty (поток вызывающего вызова может выполнять другую работу)-> Ответ приходит> nettyexecutescallback-> Расписание Остальная часть обработки в потоке приложения (уже обработанное))

Подробнее здесь: https://stackoverflow.com/questions/797 ... io-threads