6

我已经实现了一个异步服务器消息流，并且我有调用 rpc 的测试，然后导致从服务器发送一条消息，然后等待onNext().

有时测试会失败，因为 rpc 调用在我发出消息后到达服务器。如果我在服务器端添加 300 毫秒的睡眠，它会一直失败。

我试过添加withWaitForReady()它并没有帮助。

是否有一种标准方法可以阻止异步存根，直到服务器端的方法完成？

4

0 回答 0