order(List<Entry<K, V>> insertionOrder) { L156: insertionOrder = castOrCopyToList(delegate.order(insertionOrder)); L157: reverse(insertionOrder); L158: return insertionOrder; L159: } L160: L161: TestSortedMapGenerator<K, V> delegate() { L162: return (TestSortedMapGenerator<K, V>) delegate; L163: } L164: L165: @Override L166: public Entry<K, V> belowSamplesLesser() { L167: return delegate().aboveSamplesGreater(); L168: } L169: L170: @Override L171: public Entry<K, V>...

TestMultisetGenerator<E> { L288: private final TestMultisetGenerator<E> delegate; L289: L290: ForwardingTestMultisetGenerator(TestMultisetGenerator<E> delegate) { L291: this.delegate = delegate; L292: } L293: L294: @Override L295: public SampleElements<E> samples() { L296: return delegate.samples(); L297: } L298: L299: @Override L300: public E[] createArray(int length) { L301: return delegate.createArray(length); L302: } L303: L304: @Override L305: public...

ap<K, V> extends ForwardingMap<K, V> { L51: final Map<K, V> delegate; L52: L53: UnmodifiableIteratorMap(Map<K, V> delegate) { L54: this.delegate = delegate; L55: } L56: L57: @Override L58: protected Map<K, V> delegate() { L59: return delegate; L60: } L61: L62: @Override L63: public Set<K> keySet() { L64: return new ForwardingSet<K>() { L65: @Override L66: protected Set<K> delegate() { L67: return delegate.keySet(); L68: } L69: L70:...

implements ListeningScheduledExecutorService { L50: L51: private final ListeningExecutorService delegate = newDirectExecutorService(); L52: L53: @Override L54: public void shutdown() { L55: delegate.shutdown(); L56: } L57: L58: @Override L59: public List<Runnable> shutdownNow() { L60: return delegate.shutdownNow(); L61: } L62: L63: @Override L64: public boolean isShutdown() { L65: return delegate.isShutdown(); L66: } L67: L68: @Override L69: public boolean isTerminated() { L70: return...

implements ListeningScheduledExecutorService { L50: L51: private final ListeningExecutorService delegate = newDirectExecutorService(); L52: L53: @Override L54: public void shutdown() { L55: delegate.shutdown(); L56: } L57: L58: @Override L59: public List<Runnable> shutdownNow() { L60: return delegate.shutdownNow(); L61: } L62: L63: @Override L64: public boolean isShutdown() { L65: return delegate.isShutdown(); L66: } L67: L68: @Override L69: public boolean isTerminated() { L70: return...

// TODO L464: public static ListeningExecutorService listeningDecorator(ExecutorService delegate) { L465: return (delegate instanceof ListeningExecutorService) L466: ? (ListeningExecutorService) delegate L467: : (delegate instanceof ScheduledExecutorService) L468: ? new ScheduledListeningDecorator((ScheduledExecutorService) delegate) L469: : new ListeningDecorator(delegate); L470: } L471: L472: /** L473: * Creates a {@link ScheduledExecutorService} whose...

protected ForwardingMap() {} L65: L66: @Override L67: protected abstract Map<K, V> delegate(); L68: L69: @Override L70: public int size() { L71: return delegate().size(); L72: } L73: L74: @Override L75: public boolean isEmpty() { L76: return delegate().isEmpty(); L77: } L78: L79: @CanIgnoreReturnValue L80: @Override L81: @CheckForNull L82: public V remove(@CheckForNull Object key) { L83: return delegate().remove(key); L84: } L85: L86: @Override L87: public void clear() { L88: ...

" [" + state() + "]"; L153: } L154: L155: @Override L156: public final boolean isRunning() { L157: return delegate.isRunning(); L158: } L159: L160: @Override L161: public final State state() { L162: return delegate.state(); L163: } L164: L165: /** @since 13.0 */ L166: @Override L167: public final void addListener(Listener listener, Executor executor) { L168: delegate.addListener(listener, executor); L169: } L170: L171: /** @since 14.0 */ L172: @Override L173: public final Throwable...

class ForwardingCondition implements Condition { L26: abstract Condition delegate(); L27: L28: @Override L29: public void await() throws InterruptedException { L30: delegate().await(); L31: } L32: L33: @Override L34: public boolean await(long time, TimeUnit unit) throws InterruptedException { L35: return delegate().await(time, unit); L36: } L37: L38: @Override L39: public void awaitUninterruptibly() { L40: delegate().awaitUninterruptibly(); L41: } L42: L43: @Override L44: public long...

= new ExecutionList(); L118: L119: // This allows us to only start up a thread waiting on the delegate future when the first L120: // listener is added. L121: private final AtomicBoolean hasListeners = new AtomicBoolean(false); L122: L123: // The delegate future. L124: private final Future<V> delegate; L125: L126: ListenableFutureAdapter(Future<V> delegate) { L127: this(delegate, defaultAdapterExecutor); L128: } L129: L130: ListenableFutureAdapter(Future<V> delegate, Executor...