Searched refs:awaitOnReadyAndDrain (Results 1 – 1 of 1) sorted by relevance
713 assertTrue(clientStreamListener.awaitOnReadyAndDrain(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in basicStream()765 assertTrue(serverStreamListener.awaitOnReadyAndDrain(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in basicStream()1125 assertTrue(serverStreamListener.awaitOnReadyAndDrain(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in clientCancelFromWithinMessageRead()1235 assertTrue(clientStreamListener.awaitOnReadyAndDrain(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in flowControlPushBack()1260 assertTrue(serverStreamListener.awaitOnReadyAndDrain(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in flowControlPushBack()1297 assertTrue(clientStreamListener.awaitOnReadyAndDrain(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in flowControlPushBack()1299 assertTrue(serverStreamListener.awaitOnReadyAndDrain(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in flowControlPushBack()1907 private boolean awaitOnReadyAndDrain(int timeout, TimeUnit unit) throws Exception { in awaitOnReadyAndDrain() method in AbstractTransportTest.ServerStreamListenerBase1968 private boolean awaitOnReadyAndDrain(int timeout, TimeUnit unit) throws Exception { in awaitOnReadyAndDrain() method in AbstractTransportTest.ClientStreamListenerBase