Searched refs:PendingStream (Results 1 – 1 of 1) sorted by relevance
65 private Collection<PendingStream> pendingStreams = new LinkedHashSet<PendingStream>();179 private PendingStream createPendingStream(PickSubchannelArgs args) { in createPendingStream()180 PendingStream pendingStream = new PendingStream(args); in createPendingStream()233 Collection<PendingStream> savedPendingStreams; in shutdownNow()240 pendingStreams = Collections.<PendingStream>emptyList(); in shutdownNow()244 for (PendingStream stream : savedPendingStreams) { in shutdownNow()277 ArrayList<PendingStream> toProcess; in reprocess()286 ArrayList<PendingStream> toRemove = new ArrayList<>(); in reprocess()288 for (final PendingStream stream : toProcess) { in reprocess()322 pendingStreams = new LinkedHashSet<PendingStream>(); in reprocess()[all …]