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

abstract class ForwardingImmutableSet<E> extends ImmutableSet<E> { L32: private final transient Set<E> delegate; L33: L34: ForwardingImmutableSet(Set<E> delegate) { L35: // TODO(cpovirk): are we over-wrapping? L36: this.delegate = Collections.unmodifiableSet(delegate); L37: } L38: L39: @Override L40: public UnmodifiableIterator<E> iterator() { L41: return Iterators.unmodifiableIterator(delegate.iterator()); L42: } L43: L44: @Override L45: public boolean contains(@Nullable Object object)...

isPrevDirection && activeIndex === 0 ||\n isNextDirection && activeIndex === lastItemIndex\n\n if (isGoingToWrap && !this._config.wrap) {\n return activeElement\n }\n\n const delta = direction === Direction.PREV ? -1 : 1\n const itemIndex = (activeIndex + delta) % this._items.length\n\n return itemIndex === -1\n ? this._items[this._items.length - 1] : this._items[itemIndex]\n }\n\n _triggerSlideEvent(relatedTarget, eventDirectionName) {\n const targetIndex...

ImmutableCollection<E> { L31: L32: final transient Collection<E> delegate; L33: L34: ForwardingImmutableCollection(Collection<E> delegate) { L35: this.delegate = delegate; L36: } L37: L38: @Override L39: public UnmodifiableIterator<E> iterator() { L40: return Iterators.unmodifiableIterator(delegate.iterator()); L41: } L42: L43: @Override L44: public boolean contains(@Nullable Object object) { L45: return object != null && delegate.contains(object); L46: } L47: L48: @Override L49: public...

L29: } L30: L31: private InvalidatableSet( L32: Set<E> delegate, Supplier<Boolean> validator, Supplier<String> errorMessage) { L33: this.delegate = delegate; L34: this.validator = validator; L35: this.errorMessage = errorMessage; L36: } L37: L38: // Override hashCode() to access delegate directly (so that it doesn't trigger the validate() call L39: // via delegate()); it seems inappropriate to throw ISE on this method. L40: @Override L41: public int hashCode() { L42: return...

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

{@link LoadingCache} as the delegate. L76: * L77: * @since 10.0 L78: */ L79: public abstract static class SimpleForwardingLoadingCache<K, V> L80: extends ForwardingLoadingCache<K, V> { L81: private final LoadingCache<K, V> delegate; L82: L83: protected SimpleForwardingLoadingCache(LoadingCache<K, V> delegate) { L84: this.delegate = Preconditions.checkNotNull(delegate); L85: } L86: L87: @Override L88: protected final LoadingCache<K, V> delegate() { L89: return delegate;...

implements Deque<E> { L41: private final Deque<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...

extends UnmodifiableMultiset<E> L33: implements SortedMultiset<E> { L34: UnmodifiableSortedMultiset(SortedMultiset<E> delegate) { L35: super(delegate); L36: } L37: L38: @Override L39: protected SortedMultiset<E> delegate() { L40: return (SortedMultiset<E>) super.delegate(); L41: } L42: L43: @Override L44: public Comparator<? super E> comparator() { L45: return delegate().comparator(); L46: } L47: L48: @Override L49: SortedSet<E> createElementSet() { L50: return Collections.unm...