Searched refs:streamExecutor (Results 1 – 1 of 1) sorted by relevance
88 private final ListeningExecutorService streamExecutor = MoreExecutors.listeningDecorator( field in StreamService142 streamExecutor.shutdown(); in doStart()145 streamExecutor.awaitTermination(10, TimeUnit.MILLISECONDS); in doStart()149 streamExecutor.shutdownNow(); in doStart()161 streamExecutor.submit( in doStart()165 streamExecutor.submit( in doStart()179 streamExecutor.submit(threadRenaming("worker-socket", in doStart()245 final ListenableFuture<Integer> processFuture = streamExecutor.submit(new Callable<Integer>() { in doStop()253 streamExecutor.submit(new Callable<Void>() { in doStop()