Searched refs:getExecutor (Results 1 – 12 of 12) 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()
90 firstNonNull(callOptions.getExecutor(), appExecutor), applier); in newStream()
805 Executor executor = callOptions.getExecutor(); in getCallExecutor()
176 private static synchronized ExecutorService getExecutor() { in getExecutor() method in Utils220 builder.executor(getExecutor()); in newClientChannel()
106 vr_executor* getExecutor (void) const;
665 vr_executor* Context::getExecutor (void) const in getExecutor() function in vkt::Context
226 vr_result res = vr_executor_execute_script(m_context.getExecutor(), m_testCaseData.script); in iterate()
352 public Executor getExecutor() { in getExecutor() method in CallOptions