Я реализовал поток сообщений асинхронного сервера, и у меня есть тесты, которые вызывают rpc, затем вызывают отправку сообщения с сервера и затем ожидают onNext().
Иногда тесты не выполняются, потому что вызов rpc поступает на сервер после того, как я вызываю сообщение. Если я добавлю спящий режим на 300 миллисекунд на стороне сервера, он будет постоянно зависать.
Я пытался добавить withWaitForReady(), но это не помогло.
Существует ли стандартный способ блокировки асинхронной заглушки, пока метод на стороне сервера не будет завершен?