Searched refs:drainedSubstreams (Results 1 – 1 of 1) sorted by relevance
122 final Collection<Substream> savedDrainedSubstreams = state.drainedSubstreams; in commit()316 savedDrainedSubstreams = state.drainedSubstreams; in delayOrExecute()388 for (Substream substream : state.drainedSubstreams) { in isReady()694 if (state.drainedSubstreams.contains(substream)) { in onReady()711 final Collection<Substream> drainedSubstreams; field in RetriableStream.State721 Collection<Substream> drainedSubstreams, in State() argument726 this.drainedSubstreams = in State()727 checkNotNull(drainedSubstreams, "drainedSubstreams"); in State()738 || (drainedSubstreams.size() == 1 && drainedSubstreams.contains(winningSubstream)) in State()739 || (drainedSubstreams.size() == 0 && winningSubstream.closed), in State()[all …]