Searched refs:lbRequestObservers (Results 1 – 1 of 1) sorted by relevance
149 private final LinkedList<StreamObserver<LoadBalanceRequest>> lbRequestObservers = field in GrpclbLoadBalancerTest196 lbRequestObservers.add(requestObserver); in setUp()408 assertEquals(1, lbRequestObservers.size()); in loadReporting()409 StreamObserver<LoadBalanceRequest> lbRequestObserver = lbRequestObservers.poll(); in loadReporting()565 assertEquals(1, lbRequestObservers.size()); in loadReporting()566 lbRequestObserver = lbRequestObservers.poll(); in loadReporting()659 assertEquals(1, lbRequestObservers.size()); in raceBetweenLoadReportingAndLbStreamClosure()660 StreamObserver<LoadBalanceRequest> lbRequestObserver = lbRequestObservers.poll(); in raceBetweenLoadReportingAndLbStreamClosure()803 assertEquals(1, lbRequestObservers.size()); in grpclbUpdatedAddresses_avoidsReconnect()813 assertEquals(1, lbRequestObservers.size()); // No additional RPC in grpclbUpdatedAddresses_avoidsReconnect()[all …]