Searched refs:pendingStreams (Results 1 – 4 of 4) sorted by relevance
65 private Collection<PendingStream> pendingStreams = new LinkedHashSet<PendingStream>(); field in DelayedClientTransport181 pendingStreams.add(pendingStream); in createPendingStream()236 savedPendingStreams = pendingStreams; in shutdownNow()239 if (!pendingStreams.isEmpty()) { in shutdownNow()240 pendingStreams = Collections.<PendingStream>emptyList(); in shutdownNow()255 return !pendingStreams.isEmpty(); in hasPendingStreams()262 return pendingStreams.size(); in getPendingStreamsCount()284 toProcess = new ArrayList<>(pendingStreams); in reprocess()318 pendingStreams.removeAll(toRemove); in reprocess()321 if (pendingStreams.isEmpty()) { in reprocess()[all …]
182 private LinkedList<OkHttpClientStream> pendingStreams = new LinkedList<OkHttpClientStream>(); field in OkHttpClientTransport359 pendingStreams.add(clientStream); in streamReadyToStart()395 while (!pendingStreams.isEmpty() && streams.size() < maxConcurrentStreams) { in startPendingStreams()396 OkHttpClientStream stream = pendingStreams.poll(); in startPendingStreams()408 pendingStreams.remove(pendingStream); in removePendingStream()693 for (OkHttpClientStream stream : pendingStreams) { in shutdownNow()696 pendingStreams.clear(); in shutdownNow()725 return pendingStreams.size(); in getPendingStreamSize()769 for (OkHttpClientStream stream : pendingStreams) { in startGoAway()773 pendingStreams.clear(); in startGoAway()[all …]
META-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...