future = SettableFuture.create(); L319: final Executor delegate = L320: new Executor() { L321: @Override L322: public void execute(Runnable task) { L323: if (future.set(null)) { L324: awaitUninterruptibly(latch); L325: } L326: throw new RejectedExecutionException(); L327: } L328: }; L329: final SequentialExecutor executor = new SequentialExecutor(delegate); L330: final ExecutorService blocked = Executors....

future = SettableFuture.create(); L319: final Executor delegate = L320: new Executor() { L321: @Override L322: public void execute(Runnable task) { L323: if (future.set(null)) { L324: awaitUninterruptibly(latch); L325: } L326: throw new RejectedExecutionException(); L327: } L328: }; L329: final SequentialExecutor executor = new SequentialExecutor(delegate); L330: final ExecutorService blocked = Executors....

protected ForwardingListIterator() {} L46: L47: @Override L48: protected abstract ListIterator<E> delegate(); L49: L50: @Override L51: public void add(@ParametricNullness E element) { L52: delegate().add(element); L53: } L54: L55: @Override L56: public boolean hasPrevious() { L57: return delegate().hasPrevious(); L58: } L59: L60: @Override L61: public int nextIndex() { L62: return delegate().nextIndex(); L63: } L64: L65: @CanIgnoreReturnValue L66: @Override L67: @ParametricNullness...

compressedMessages() { L1064: successfulExtensions("permessage-deflate") L1065: } L1066: L1067: @Test L1068: @Throws(Exception::class) L1069: fun compressedMessagesNoClientContextTakeover() { L1070: successfulExtensions("permessage-deflate; client_no_context_takeover") L1071: } L1072: L1073: @Test L1074: @Throws(Exception::class) L1075: fun compressedMessagesNoServerContextTakeover() { L1076: successfulExtensions("permessage-deflate; server_no_context_takeover") L1077: } L1078: L1079: @Test...

private fun uppercaseResponse(response: Response): Response { L33: val uppercaseBody: ResponseBody = L34: object : ForwardingResponseBody(response.body) { L35: override fun source(): BufferedSource { L36: return uppercaseSource(delegate().source()).buffer() L37: } L38: } L39: return response.newBuilder() L40: .body(uppercaseBody) L41: .build() L42: } L43: L44: private fun uppercaseSource(source: BufferedSource): ForwardingSource { L45: return object...

izeAndAssert(unmodifiable); L132: } L133: L134: public void testUnmodifiableArrayListMultimapRandomAccess() { L135: ListMultimap<String, Integer> delegate = ArrayListMultimap.create(); L136: delegate.put("foo", 1); L137: delegate.put("foo", 3); L138: ListMultimap<String, Integer> multimap = Multimaps.unmodifiableListMultimap(delegate); L139: assertTrue(multimap.get("foo") instanceof RandomAccess); L140: assertTrue(multimap.get("bar") instanceof RandomAccess); L141: } L142: L143:...

} L68: L69: public static final class NavigableSetSubsetTestSetGenerator<E> L70: extends SortedSetSubsetTestSetGenerator<E> { L71: public NavigableSetSubsetTestSetGenerator( L72: TestSortedSetGenerator<E> delegate, Bound to, Bound from) { L73: super(delegate, to, from); L74: } L75: L76: @Override L77: NavigableSet<E> createSubSet(SortedSet<E> sortedSet, E firstExclusive, E lastExclusive) { L78: NavigableSet<E> set = (NavigableSet<E>) sortedSet; L79: if (from...

uppercaseRequest(request: Request): Request { L35: val uppercaseBody: RequestBody = L36: object : ForwardingRequestBody(request.body) { L37: @Throws(IOException::class) L38: override fun writeTo(sink: BufferedSink) { L39: delegate().writeTo(uppercaseSink(sink).buffer()) L40: } L41: } L42: return request.newBuilder() L43: .method(request.method, uppercaseBody) L44: .build() L45: } L46: L47: private fun uppercaseSink(sink: Sink): Sink { L48: return...

NavigableSet<E>, Serializable { L1811: private final NavigableSet<E> delegate; L1812: private final SortedSet<E> unmodifiableDelegate; L1813: L1814: UnmodifiableNavigableSet(NavigableSet<E> delegate) { L1815: this.delegate = checkNotNull(delegate); L1816: this.unmodifiableDelegate = Collections.unmodifiableSortedSet(delegate); L1817: } L1818: L1819: @Override L1820: protected SortedSet<E> delegate() { L1821: return unmodifiableDelegate; L1822: } L1823: L1824: ...

public boolean addAll(Collection<? extends V> collection) { L130: checkNotNull(collection); L131: throw new IllegalArgumentException("Key does not satisfy predicate: " + key); L132: } L133: L134: @Override L135: protected Set<V> delegate() { L136: return emptySet(); L137: } L138: } L139: L140: static class AddRejectingList<K extends @Nullable Object, V extends @Nullable Object> L141: extends ForwardingList<V> { L142: @ParametricNullness final K key; L143: L144:...