#protocol-buffers #grpc #grpc-java
#протокол-буферы #grpc #grpc-java
Вопрос:
Я реализовал поток сообщений асинхронного сервера, и у меня есть тесты, которые вызывают rpc, затем вызывают отправку сообщения с сервера, а затем ждут onNext() .
Иногда тесты завершаются неудачно, потому что вызов rpc поступает на сервер после того, как я вызываю сообщение. Если я добавлю режим ожидания в 300 миллисекунд на стороне сервера, он постоянно завершается сбоем.
Я пробовал добавлять withWaitForReady() , и это не помогло.
Существует ли стандартный способ блокировки асинхронной заглушки до завершения работы метода на стороне сервера?
Комментарии:
1. Мне непонятно, о чем спрашивают. Отчасти я не знаю, ожидает ли это клиент или сервер
onNext()и о чем идет речь «вызвать сообщение». «Блокировка» асинхронной заглушки также сбивает с толку. Попробуйте изменить формулировку?