Searched refs:lbResponseObserver (Results 1 – 1 of 1) sorted by relevance
407 StreamObserver<LoadBalanceResponse> lbResponseObserver = lbResponseObserverCaptor.getValue(); in loadReporting() local420 lbResponseObserver.onNext(buildInitialResponse(loadReportIntervalMillis)); in loadReporting()432 lbResponseObserver.onNext(buildLbResponse(backends)); in loadReporting()559 lbResponseObserver.onError(Status.UNAVAILABLE.asException()); in loadReporting()564 lbResponseObserver = lbResponseObserverCaptor.getValue(); in loadReporting()575 lbResponseObserver.onNext(buildInitialResponse(loadReportIntervalMillis)); in loadReporting()591 lbResponseObserver.onNext(buildLbResponse(backends)); in loadReporting()628 StreamObserver<LoadBalanceResponse> lbResponseObserver = lbResponseObserverCaptor.getValue(); in abundantInitialResponse() local632 lbResponseObserver.onNext(buildInitialResponse(1983)); in abundantInitialResponse()640 lbResponseObserver.onNext(buildInitialResponse(9097)); in abundantInitialResponse()[all …]