HomeSort by relevance Sort by last modified time
    Searched defs:scheduledExecutorService (Results 1 - 15 of 15) sorted by null

  /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
InProcessServerBuilder.java 32 import java.util.concurrent.ScheduledExecutorService;
95 private ObjectPool<ScheduledExecutorService> schedulerPool =
119 public InProcessServerBuilder scheduledExecutorService(
120 ScheduledExecutorService scheduledExecutorService) {
121 schedulerPool = new FixedObjectPool<ScheduledExecutorService>(
122 checkNotNull(scheduledExecutorService, "scheduledExecutorService"));
InProcessChannelBuilder.java 29 import java.util.concurrent.ScheduledExecutorService;
69 private ScheduledExecutorService scheduledExecutorService;
141 public InProcessChannelBuilder scheduledExecutorService(
142 ScheduledExecutorService scheduledExecutorService) {
143 this.scheduledExecutorService =
144 checkNotNull(scheduledExecutorService, "scheduledExecutorService");
151 return new InProcessClientTransportFactory(name, scheduledExecutorService);
    [all...]
  /external/grpc-grpc-java/core/src/test/java/io/grpc/inprocess/
InProcessChannelBuilderTest.java 25 import java.util.concurrent.ScheduledExecutorService;
51 ScheduledExecutorService scheduledExecutorService =
54 InProcessChannelBuilder builder1 = builder.scheduledExecutorService(scheduledExecutorService);
59 assertSame(scheduledExecutorService, clientTransportFactory.getScheduledExecutorService());
InProcessServerBuilderTest.java 30 import java.util.concurrent.ScheduledExecutorService;
59 ObjectPool<ScheduledExecutorService> scheduledExecutorServicePool =
61 ObjectPool<ScheduledExecutorService> expectedPool =
64 ScheduledExecutorService expected = expectedPool.getObject();
65 ScheduledExecutorService actual = scheduledExecutorServicePool.getObject();
75 ScheduledExecutorService scheduledExecutorService =
78 InProcessServerBuilder builder1 = builder.scheduledExecutorService(scheduledExecutorService);
82 ObjectPool<ScheduledExecutorService> scheduledExecutorServicePool
    [all...]
  /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
CronetChannelBuilderTest.java 34 import java.util.concurrent.ScheduledExecutorService;
100 ScheduledExecutorService scheduledExecutorService = mock(ScheduledExecutorService.class);
102 CronetChannelBuilder builder1 = builder.scheduledExecutorService(scheduledExecutorService);
106 assertSame(scheduledExecutorService, clientTransportFactory.getScheduledExecutorService());
  /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
OkHttpChannelBuilderTest.java 32 import java.util.concurrent.ScheduledExecutorService;
152 ScheduledExecutorService scheduledExecutorService =
155 OkHttpChannelBuilder builder1 = builder.scheduledExecutorService(scheduledExecutorService);
160 assertSame(scheduledExecutorService, clientTransportFactory.getScheduledExecutorService());
  /external/grpc-grpc-java/android/src/main/java/io/grpc/android/
AndroidChannelBuilder.java 41 import java.util.concurrent.ScheduledExecutorService;
150 * Set the delegate channel builder's scheduledExecutorService.
156 public AndroidChannelBuilder scheduledExecutorService(
157 ScheduledExecutorService scheduledExecutorService) {
160 .getMethod("scheduledExecutorService", ScheduledExecutorService.class)
161 .invoke(delegateBuilder, scheduledExecutorService);
165 "Failed to invoke scheduledExecutorService on delegate builder", e);
  /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
FakeClock.java 30 import java.util.concurrent.ScheduledExecutorService;
35 * A manipulated clock that exports a {@link Ticker} and a {@link ScheduledExecutorService}.
51 private final ScheduledExecutorService scheduledExecutorService = new ScheduledExecutorImpl();
111 private class ScheduledExecutorImpl implements ScheduledExecutorService {
190 * Provides a partially implemented instance of {@link ScheduledExecutorService} that uses the
193 public ScheduledExecutorService getScheduledExecutorService() {
194 return scheduledExecutorService;
FakeClockTest.java 25 import java.util.concurrent.ScheduledExecutorService;
40 ScheduledExecutorService scheduledExecutorService1 = fakeClock.getScheduledExecutorService();
41 ScheduledExecutorService scheduledExecutorService2 = fakeClock.getScheduledExecutorService();
130 ScheduledExecutorService scheduledExecutorService = fakeClock.getScheduledExecutorService();
132 scheduledExecutorService.schedule(newRunnable(), 200L, TimeUnit.NANOSECONDS);
133 scheduledExecutorService.execute(newRunnable());
134 scheduledExecutorService.schedule(newRunnable(), 0L, TimeUnit.NANOSECONDS);
135 scheduledExecutorService.schedule(newRunnable(), 80L, TimeUnit.NANOSECONDS);
136 scheduledExecutorService.schedule(newRunnable(), 90L, TimeUnit.NANOSECONDS)
    [all...]
  /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
CronetChannelBuilder.java 39 import java.util.concurrent.ScheduledExecutorService;
78 private ScheduledExecutorService scheduledExecutorService;
178 public final CronetChannelBuilder scheduledExecutorService(
179 ScheduledExecutorService scheduledExecutorService) {
180 this.scheduledExecutorService =
181 checkNotNull(scheduledExecutorService, "scheduledExecutorService");
191 scheduledExecutorService,
    [all...]
  /external/grpc-grpc-java/android/src/test/java/io/grpc/android/
AndroidChannelBuilderTest.java 41 import java.util.concurrent.ScheduledExecutorService;
120 public void scheduledExecutorService() {
121 AndroidChannelBuilder.forTarget("target").scheduledExecutorService(new ScheduledExecutorImpl());
415 private static class ScheduledExecutorImpl implements ScheduledExecutorService {
  /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
OkHttpChannelBuilder.java 51 import java.util.concurrent.ScheduledExecutorService;
152 private ScheduledExecutorService scheduledExecutorService;
388 public final OkHttpChannelBuilder scheduledExecutorService(
389 ScheduledExecutorService scheduledExecutorService) {
390 this.scheduledExecutorService =
391 checkNotNull(scheduledExecutorService, "scheduledExecutorService");
399 return new OkHttpTransportFactory(transportExecutor, scheduledExecutorService,
    [all...]
  /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
RetriableStream.java 41 import java.util.concurrent.ScheduledExecutorService;
64 private final ScheduledExecutorService scheduledExecutorService;
100 Executor callExecutor, ScheduledExecutorService scheduledExecutorService,
108 this.scheduledExecutorService = scheduledExecutorService;
597 scheduledRetry = scheduledExecutorService.schedule(
  /external/grpc-grpc-java/core/
grpc-core-1.14.0.jar 
  /external/mockito/lib/
byte-buddy-1.8.15.jar 

Completed in 527 milliseconds