Searched refs:lbStream (Results 1 – 1 of 1) sorted by relevance
137 private LbStream lbStream; field in GrpclbState194 if (lbStream == null) { in handleAddresses()259 if (lbStream != null) { in shutdownLbRpc()260 lbStream.close(null); in shutdownLbRpc()281 checkState(lbStream == null, "previous lbStream has not been cleared yet"); in startLbRpc()283 lbStream = new LbStream(stub); in startLbRpc()284 lbStream.start(); in startLbRpc()292 lbStream.lbRequestWriter.onNext(initRequest); in startLbRpc()294 lbStream.close(e); in startLbRpc()335 if (lbStream == null) { in getLoadRecorder()[all …]