Searched refs:winningSubstream (Results 1 – 1 of 1) sorted by relevance
117 private Runnable commit(final Substream winningSubstream) { in commit() argument119 if (state.winningSubstream != null) { in commit()124 state = state.committed(winningSubstream); in commit()135 if (substream != winningSubstream) { in commit()153 private void commitAndRun(Substream winningSubstream) { in commitAndRun() argument154 Runnable postCommitTask = commit(winningSubstream); in commitAndRun()208 if (savedState.winningSubstream != null && savedState.winningSubstream != substream) { in drain()233 if (savedState.winningSubstream != null && savedState.winningSubstream != substream) { in drain()239 savedState.winningSubstream == substream, in drain()303 state.winningSubstream.stream.cancel(reason); in cancel()[all …]