Searched refs:dataRequestStatusRef (Results 1 – 1 of 1) sorted by relevance
319 AtomicInteger dataRequestStatusRef = in sendDataRequest_isReceivedByObserver() local328 dataRequestStatusRef.set(status); in sendDataRequest_isReceivedByObserver()344 assertThat(dataRequestStatusRef.get()) in sendDataRequest_isReceivedByObserver()359 AtomicInteger dataRequestStatusRef = in sendDataRequest_requestTooLarge_notReceivedByObserver() local368 dataRequestStatusRef.set(status); in sendDataRequest_requestTooLarge_notReceivedByObserver()377 assertThat(dataRequestStatusRef.get()) in sendDataRequest_requestTooLarge_notReceivedByObserver()410 AtomicInteger dataRequestStatusRef = in sendDataRequests_tooFrequent_notReceivedByObserver() local424 dataRequestStatusRef.set(status); in sendDataRequests_tooFrequent_notReceivedByObserver()433 assertThat(dataRequestStatusRef.get()) in sendDataRequests_tooFrequent_notReceivedByObserver()453 AtomicInteger dataRequestStatusRef = in sendDataRequestsAtRateLimit_waitForOnePeriodThenSendAgain_isReceivedByObserver() local[all …]