implements Queue<E> { L41: private final Queue<E> delegate = Lists.newLinkedList(); L42: public final Object mutex = new Object[0]; // something Serializable L43: L44: @Override L45: public boolean offer(E o) { L46: assertTrue(Thread.holdsLock(mutex)); L47: return delegate.offer(o); L48: } L49: L50: @Override L51: public @Nullable E poll() { L52: assertTrue(Thread.holdsLock(mutex)); L53: return delegate.poll(); L54: } L55: L56: @Override L57: public...

ForwardingBlockingDeque() {} L58: L59: @Override L60: protected abstract BlockingDeque<E> delegate(); L61: L62: @Override L63: public int remainingCapacity() { L64: return delegate().remainingCapacity(); L65: } L66: L67: @Override L68: public void putFirst(E e) throws InterruptedException { L69: delegate().putFirst(e); L70: } L71: L72: @Override L73: public void putLast(E e) throws InterruptedException { L74: delegate().putLast(e); L75: } L76: L77: @Override L78: public boolean offerFirst(E...

{ L549: @Override L550: public NoDelegateToEquals apply(Equals delegate) { L551: return new NoDelegateToEquals(delegate); L552: } L553: }; L554: L555: private final Equals delegate; L556: L557: NoDelegateToEquals(Equals delegate) { L558: this.delegate = delegate; L559: } L560: L561: @Override L562: public String toString() { L563: return delegate.toString(); L564: } L565: } L566: L567: public void testExplicitEqualsAndHas...

Exception { L96: assertThat(future.setFuture(delegate)).isTrue(); L97: assertThat(future.cancel(true /* mayInterruptIfRunning */)).isTrue(); L98: assertCancelled(future, true); L99: assertCancelled(delegate, true); L100: } L101: L102: public void testSetFutureDelegateAlreadySuccessful() throws Exception { L103: delegate.set(5); L104: assertThat(future.setFuture(delegate)).isTrue(); L105: assertSuccessful(future, 5); L106: } L107: L108: public void testSetFutureDelegateLaterSuccessful()...

= 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...

L106: L107: /** L108: * An SSL socket factory that forwards all calls to a delegate. Override {@link #configureSocket} L109: * to customize a created socket before it is returned. L110: */ L111: static class DelegatingSSLSocketFactory extends SSLSocketFactory { L112: protected final SSLSocketFactory delegate; L113: L114: DelegatingSSLSocketFactory(SSLSocketFactory delegate) { L115: this.delegate = delegate; L116: } L117: L118: @Override public String[] getDefaultCipherSuites()...

FluentFuture<V> { L39: private final ListenableFuture<V> delegate; L40: L41: ForwardingFluentFuture(ListenableFuture<V> delegate) { L42: this.delegate = checkNotNull(delegate); L43: } L44: L45: @Override L46: public void addListener(Runnable listener, Executor executor) { L47: delegate.addListener(listener, executor); L48: } L49: L50: @Override L51: public boolean cancel(boolean mayInterruptIfRunning) { L52: return delegate.cancel(mayInterruptIfRunning); L53: } L54: L55: @Override...

ForwardingBlockingDeque() {} L56: L57: @Override L58: protected abstract BlockingDeque<E> delegate(); L59: L60: @Override L61: public int remainingCapacity() { L62: return delegate().remainingCapacity(); L63: } L64: L65: @Override L66: public void putFirst(E e) throws InterruptedException { L67: delegate().putFirst(e); L68: } L69: L70: @Override L71: public void putLast(E e) throws InterruptedException { L72: delegate().putLast(e); L73: } L74: L75: @Override L76: public boolean offerFirst(E...

" [" + state() + "]"; L116: } L117: L118: @Override L119: public final boolean isRunning() { L120: return delegate.isRunning(); L121: } L122: L123: @Override L124: public final State state() { L125: return delegate.state(); L126: } L127: L128: /** @since 13.0 */ L129: @Override L130: public final void addListener(Listener listener, Executor executor) { L131: delegate.addListener(listener, executor); L132: } L133: L134: /** @since 14.0 */ L135: @Override L136: public final Throwable...

@Override L93: public boolean isTerminated() { L94: return delegate().isTerminated(); L95: } L96: L97: @Override L98: public void shutdown() { L99: delegate().shutdown(); L100: } L101: L102: @Override L103: @CanIgnoreReturnValue L104: public List<Runnable> shutdownNow() { L105: return delegate().shutdownNow(); L106: } L107: L108: @Override L109: public void execute(Runnable command) { L110: delegate().execute(command); L111: } L112: L113: @Override L114: public <T extends @Nullable...