Home
last modified time | relevance | path

Searched defs:lbRequestObserver (Results 1 – 1 of 1) sorted by relevance

/aosp_15_r20/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
H A DGrpclbLoadBalancerTest.java426 StreamObserver<LoadBalanceRequest> lbRequestObserver = lbRequestObservers.poll(); in loadReporting() local
682 StreamObserver<LoadBalanceRequest> lbRequestObserver = lbRequestObservers.poll(); in raceBetweenHandleAddressesAndLbStreamClosure() local
727 StreamObserver<LoadBalanceRequest> lbRequestObserver = lbRequestObservers.poll(); in raceBetweenLoadReportingAndLbStreamClosure() local
759 InOrder inOrder, StreamObserver<LoadBalanceRequest> lbRequestObserver, in assertNextReport()
913 StreamObserver<LoadBalanceRequest> lbRequestObserver = lbRequestObservers.poll(); in grpclbWorking() local
1214 StreamObserver<LoadBalanceRequest> lbRequestObserver = lbRequestObservers.poll(); in subtestGrpclbFallbackTimeout() local
1366 StreamObserver<LoadBalanceRequest> lbRequestObserver = lbRequestObservers.poll(); in grpclbFallback_breakLbStreamBeforeFallbackTimerExpires() local
1537 StreamObserver<LoadBalanceRequest> lbRequestObserver = lbRequestObservers.poll(); in subtestGrpclbFallbackConnectionLost() local
1627 StreamObserver<LoadBalanceRequest> lbRequestObserver = lbRequestObservers.poll(); in grpclbFallback_allLost_failToFallback() local
1801 StreamObserver<LoadBalanceRequest> lbRequestObserver = lbRequestObservers.poll(); in grpclbBalancerStreamClosedAndRetried() local
[all …]