Searched refs:bufferEntry (Results 1 – 1 of 1) sorted by relevance
231 for (BufferEntry bufferEntry : list) { in drain()243 bufferEntry.runWith(substream); in drain()310 private void delayOrExecute(BufferEntry bufferEntry) { in delayOrExecute() argument314 state.buffer.add(bufferEntry); in delayOrExecute()320 bufferEntry.runWith(substream); in delayOrExecute()