|
32 | 32 | import io.grpc.ManagedChannel; |
33 | 33 | import io.grpc.MethodDescriptor; |
34 | 34 | import io.grpc.okhttp.OkHttpChannelBuilder; |
35 | | -import java.util.Collection; |
36 | 35 | import java.util.HashSet; |
37 | | -import java.util.List; |
38 | | -import java.util.concurrent.Callable; |
39 | | -import java.util.concurrent.Future; |
40 | | -import java.util.concurrent.ScheduledExecutorService; |
41 | | -import java.util.concurrent.ScheduledFuture; |
42 | 36 | import java.util.concurrent.TimeUnit; |
43 | 37 | import org.junit.Before; |
44 | 38 | import org.junit.Test; |
@@ -388,94 +382,4 @@ public void enterIdle() { |
388 | 382 | enterIdleCount++; |
389 | 383 | } |
390 | 384 | } |
391 | | - |
392 | | - private static class ScheduledExecutorImpl implements ScheduledExecutorService { |
393 | | - @Override |
394 | | - public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) { |
395 | | - throw new UnsupportedOperationException(); |
396 | | - } |
397 | | - |
398 | | - @Override |
399 | | - public ScheduledFuture<?> schedule(Runnable cmd, long delay, TimeUnit unit) { |
400 | | - throw new UnsupportedOperationException(); |
401 | | - } |
402 | | - |
403 | | - @Override |
404 | | - public ScheduledFuture<?> scheduleAtFixedRate( |
405 | | - Runnable command, long initialDelay, long period, TimeUnit unit) { |
406 | | - throw new UnsupportedOperationException(); |
407 | | - } |
408 | | - |
409 | | - @Override |
410 | | - public ScheduledFuture<?> scheduleWithFixedDelay( |
411 | | - Runnable command, long initialDelay, long delay, TimeUnit unit) { |
412 | | - throw new UnsupportedOperationException(); |
413 | | - } |
414 | | - |
415 | | - @Override |
416 | | - public boolean awaitTermination(long timeout, TimeUnit unit) { |
417 | | - throw new UnsupportedOperationException(); |
418 | | - } |
419 | | - |
420 | | - @Override |
421 | | - public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) { |
422 | | - throw new UnsupportedOperationException(); |
423 | | - } |
424 | | - |
425 | | - @Override |
426 | | - public <T> List<Future<T>> invokeAll( |
427 | | - Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) { |
428 | | - throw new UnsupportedOperationException(); |
429 | | - } |
430 | | - |
431 | | - @Override |
432 | | - public <T> T invokeAny(Collection<? extends Callable<T>> tasks) { |
433 | | - throw new UnsupportedOperationException(); |
434 | | - } |
435 | | - |
436 | | - @Override |
437 | | - public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) { |
438 | | - throw new UnsupportedOperationException(); |
439 | | - } |
440 | | - |
441 | | - @Override |
442 | | - public boolean isShutdown() { |
443 | | - throw new UnsupportedOperationException(); |
444 | | - } |
445 | | - |
446 | | - @Override |
447 | | - public boolean isTerminated() { |
448 | | - throw new UnsupportedOperationException(); |
449 | | - } |
450 | | - |
451 | | - @Override |
452 | | - public void shutdown() { |
453 | | - throw new UnsupportedOperationException(); |
454 | | - } |
455 | | - |
456 | | - @Override |
457 | | - public List<Runnable> shutdownNow() { |
458 | | - throw new UnsupportedOperationException(); |
459 | | - } |
460 | | - |
461 | | - @Override |
462 | | - public <T> Future<T> submit(Callable<T> task) { |
463 | | - throw new UnsupportedOperationException(); |
464 | | - } |
465 | | - |
466 | | - @Override |
467 | | - public Future<?> submit(Runnable task) { |
468 | | - throw new UnsupportedOperationException(); |
469 | | - } |
470 | | - |
471 | | - @Override |
472 | | - public <T> Future<T> submit(Runnable task, T result) { |
473 | | - throw new UnsupportedOperationException(); |
474 | | - } |
475 | | - |
476 | | - @Override |
477 | | - public void execute(Runnable command) { |
478 | | - throw new UnsupportedOperationException(); |
479 | | - } |
480 | | - } |
481 | 385 | } |
0 commit comments