Searched refs:dataRequestStatusLatch (Results 1 – 1 of 1) sorted by relevance
321 CountDownLatch dataRequestStatusLatch = new CountDownLatch(1); in sendDataRequest_isReceivedByObserver() local329 dataRequestStatusLatch.countDown(); in sendDataRequest_isReceivedByObserver()343 assertThat(dataRequestStatusLatch.await(3, SECONDS)).isTrue(); in sendDataRequest_isReceivedByObserver()361 CountDownLatch dataRequestStatusLatch = new CountDownLatch(1); in sendDataRequest_requestTooLarge_notReceivedByObserver() local369 dataRequestStatusLatch.countDown(); in sendDataRequest_requestTooLarge_notReceivedByObserver()376 assertThat(dataRequestStatusLatch.await(3, SECONDS)).isTrue(); in sendDataRequest_requestTooLarge_notReceivedByObserver()412 CountDownLatch dataRequestStatusLatch = new CountDownLatch(1); in sendDataRequests_tooFrequent_notReceivedByObserver() local425 dataRequestStatusLatch.countDown(); in sendDataRequests_tooFrequent_notReceivedByObserver()432 assertThat(dataRequestStatusLatch.await(3, SECONDS)).isTrue(); in sendDataRequests_tooFrequent_notReceivedByObserver()455 CountDownLatch dataRequestStatusLatch = new CountDownLatch(1); in sendDataRequestsAtRateLimit_waitForOnePeriodThenSendAgain_isReceivedByObserver() local[all …]