Searched refs:getExecutor (Results 1 – 10 of 10) sorted by relevance
68 assertThat(CallOptions.DEFAULT.getExecutor()).isNull(); in defaultsAreAllNull()88 assertThat(allSet.getExecutor()).isSameAs(directExecutor()); in allWiths()125 assertThat(CallOptions.DEFAULT.getExecutor()).isNull(); in mutateExecutor()126 assertThat(executor).isSameAs(options1.getExecutor()); in mutateExecutor()129 assertThat(executor).isSameAs(options1.getExecutor()); in mutateExecutor()130 assertThat(options2.getExecutor()).isNull(); in mutateExecutor()
93 assertNull(callOptions.getExecutor()); in withExecutor()99 assertEquals(callOptions.getExecutor(), executor); in withExecutor()
96 serverBuilder.executor(getExecutor(asyncThreads)); in LoadServer()104 serverBuilder.executor(getExecutor(asyncThreads)); in LoadServer()144 ExecutorService getExecutor(int asyncThreads) { in getExecutor() method in LoadServer
298 if (callOptions.getExecutor() != null) { in reprocess()299 executor = callOptions.getExecutor(); in reprocess()
196 callOptions.getExecutor() == null ? executor : callOptions.getExecutor(), in newCall()
91 firstNonNull(callOptions.getExecutor(), appExecutor), applier); in newStream()
786 Executor executor = callOptions.getExecutor(); in getCallExecutor()
176 private static synchronized ExecutorService getExecutor() { in getExecutor() method in Utils220 builder.executor(getExecutor()); in newClientChannel()
352 public Executor getExecutor() { in getExecutor() method in CallOptions
304 public abstract fun getExecutor ()Ljava/util/concurrent/Executor;1177 public fun getExecutor ()Ljava/util/concurrent/Executor;