ForwardingConcurrentMapTest extends TestCase { L29: L30: private static class TestMap extends ForwardingConcurrentMap<String, Integer> { L31: final ConcurrentMap<String, Integer> delegate = new ConcurrentHashMap<>(); L32: L33: @Override L34: protected ConcurrentMap<String, Integer> delegate() { L35: return delegate; L36: } L37: } L38: L39: public void testPutIfAbsent() { L40: TestMap map = new TestMap(); L41: map.put("foo", 1); L42: assertEquals(Integer.valueOf(1), map.putIfAbsent("foo",...

parentBuilder, L114: Bound from, L115: Bound to) { L116: TestSortedMapGenerator<K, V> delegate = L117: (TestSortedMapGenerator<K, V>) parentBuilder.getSubjectGenerator().getInnerGenerator(); L118: L119: List<Feature<?>> features = new ArrayList<>(); L120: features.add(NoRecurse.SUBMAP); L121: features.addAll(parentBuilder.getFeatures()); L122: L123: return newBuilderUsing(delegate, to, from) L124: .named(parentBuilder.getName() + " subMap " + from + "-" + to) L125:...

} L321: L322: c = c.superclass L323: } L324: L325: // Didn't find the field we wanted. As a last gasp attempt, L326: // try to find the value on a delegate. L327: if (fieldName != "delegate") { L328: val delegate = readFieldOrNull(instance, Any::class.java, "delegate") L329: if (delegate != null) return readFieldOrNull(delegate, fieldType, fieldName) L330: } L331: L332: return null L333:} L334: L335:@JvmField L336:internal val assertionsEnabled: Boolean = OkHttpClient::class.jav...

fun getDefaultCipherSuites(): Array<String> { L76: return delegate.defaultCipherSuites L77: } L78: L79: override fun getSupportedCipherSuites(): Array<String> { L80: return delegate.supportedCipherSuites L81: } L82: L83: @Throws(IOException::class) L84: override fun createSocket( L85: socket: Socket, L86: host: String, L87: port: Int, L88: autoClose: Boolean, L89: ): SSLSocket { L90: val sslSocket = delegate.createSocket(socket, host, port, autoClose) as SSLSocket L91:...

L28:final class RegularImmutableSet<E> extends ForwardingImmutableSet<E> { L29: static final RegularImmutableSet<Object> EMPTY = L30: new RegularImmutableSet<Object>(Collections.emptySet()); L31: L32: RegularImmutableSet(Set<E> delegate) { L33: super(delegate); L34: } L35:}...

get(int index) { L79: return delegate().get(index); L80: } L81: L82: @Override L83: public int indexOf(@CheckForNull Object element) { L84: return delegate().indexOf(element); L85: } L86: L87: @Override L88: public int lastIndexOf(@CheckForNull Object element) { L89: return delegate().lastIndexOf(element); L90: } L91: L92: @Override L93: public ListIterator<E> listIterator() { L94: return delegate().listIterator(); L95: } L96: L97: @Override L98: public ListIterator<E> listIterator(int...

/** A wrapped future that does not propagate cancellation to its delegate. */ L799: private static final class NonCancellationPropagatingFuture<V extends @Nullable Object> L800: extends AbstractFuture.TrustedFuture<V> implements Runnable { L801: @CheckForNull @LazyInit private ListenableFuture<V> delegate; L802: L803: NonCancellationPropagatingFuture(final ListenableFuture<V> delegate) { L804: this.delegate = delegate; L805: } L806: L807: @Override L808: public void run()...

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

threadSum--; L82: break; L83: case 5: L84: map.getAndAdd(key, delta); L85: threadSum += delta; L86: break; L87: case 6: L88: long oldValue = map.put(key, delta); L89: threadSum += delta - oldValue; L90: break; L91: case 7: L92: oldValue = map.get(key);...