Searched refs:runningReadStreams (Results 1 – 1 of 1) sorted by relevance
109 private final AtomicInteger runningReadStreams = new AtomicInteger(); field in StreamService159 runningReadStreams.addAndGet(2); in doStart()177 runningReadStreams.addAndGet(1); in doStart()285 if (runningReadStreams.decrementAndGet() == 0) { in closeReadStream()