Searched refs:openStreams (Results 1 – 1 of 1) sorted by relevance
103 private final AtomicInteger openStreams = new AtomicInteger(); field in StreamService160 openStreams.addAndGet(1); in doStart()178 openStreams.addAndGet(1); in doStart()240 if (openStreams.get() > 0) { in doStop()279 if (openStreams.decrementAndGet() == 0) { in closeStream()