okhttp3.internal.connection L17: L18:/** L19: * A RoutePlanner that will always establish a new connection, ignoring any connection pooling L20: */ L21:class ForceConnectRoutePlanner(private val delegate: RealRoutePlanner) : RoutePlanner by delegate { L22: override fun plan(): RoutePlanner.Plan = delegate.planConnect() // not delegate.plan() L23:}...

L346: * like [poll]. It is only usable within task faker tasks. L347: */ L348: private inner class TaskFakerBlockingQueue<T>( L349: val delegate: BlockingQueue<T>, L350: ) : AbstractQueue<T>(), BlockingQueue<T> { L351: override val size: Int = delegate.size L352: L353: private var editCount = 0 L354: L355: override fun poll(): T = delegate.poll() L356: L357: override fun poll( L358: timeout: Long, L359: unit: TimeUnit, L360: ): T? { L361: taskRunner.lock.withLock...

Views L452: L453: @Override L454: Set<E> createElementSet() { L455: Set<E> delegate = countMap.keySet(); L456: return new ForwardingSet<E>() { L457: @Override L458: protected Set<E> delegate() { L459: return delegate; L460: } L461: L462: @Override L463: public boolean contains(@CheckForNull Object object) { L464: return object != null && Collections2.safeContains(delegate, object); L465: } L466: L467: @Override L468: public boolean con...

org.junit.jupiter.api.Tag L32:import org.junit.jupiter.api.Test L33: L34:/** L35: * Tests for ALPN overriding on Android. L36: */ L37:@Tag("Remote") L38:class AlpnOverrideTest { L39: class CustomSSLSocketFactory( L40: delegate: SSLSocketFactory, L41: ) : DelegatingSSLSocketFactory(delegate) { L42: override fun configureSocket(sslSocket: SSLSocket): SSLSocket { L43: if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.N) { L44: val parameters = sslSocket.sslParameters L45: Log.d("Cu...

Serializable { L29: private int value; L30: L31: Count(int value) { L32: this.value = value; L33: } L34: L35: public int get() { L36: return value; L37: } L38: L39: public void add(int delta) { L40: value += delta; L41: } L42: L43: public int addAndGet(int delta) { L44: return value += delta; L45: } L46: L47: public void set(int newValue) { L48: value = newValue; L49: } L50: L51: public int getAndSet(int newValue) { L52: int result = value; L53: value = newValue; L54:...

mockwebserver3.Dispatcher { L35: if (this is QueueDispatcher) return this.delegate L36: L37: val delegate = this L38: return object : mockwebserver3.Dispatcher() { L39: override fun dispatch(request: mockwebserver3.RecordedRequest): mockwebserver3.MockResponse { L40: return delegate.dispatch(request.unwrap()).wrap() L41: } L42: L43: override fun peek(): mockwebserver3.MockResponse { L44: return delegate.peek().wrap() L45: } L46: L47: override fun shutdown() { L48: delegate.shutdown()...

protected char[] escapeUnsafe(char c) { L73: return noChars; L74: } L75: }; L76: EscaperAsserts.assertBasic(deletingEscaper); L77: assertEquals( L78: "Everything outside the printable ASCII range is deleted.", L79: deletingEscaper.escape( L80: "\tEverything\0 outside the\uD800\uDC00 " L81: + "printable ASCII \uFFFFrange is \u007Fdeleted.\n")); L82: } L83: L84: public void testReplacementPriority() throws IOException...

L126: public EqualsTester testEquals() { L127: RelationshipTester<Object> delegate = L128: new RelationshipTester<>( L129: Equivalence.equals(), "Object#equals", "Object#hashCode", itemReporter); L130: for (List<Object> group : equalityGroups) { L131: delegate.addRelatedGroup(group); L132: } L133: for (int run = 0; run < REPETITIONS; run++) { L134: testItems(); L135: delegate.test(); L136: } L137: return this; L138: } L139: L140: private void testItems()...

charset: Charset, L186: ) : Reader() { L187: private var closed: Boolean = false L188: private var delegate: Reader? = null L189: L190: @Throws(IOException::class) L191: override fun read( L192: cbuf: CharArray, L193: off: Int, L194: len: Int, L195: ): Int { L196: if (closed) throw IOException("Stream closed") L197: L198: val finalDelegate = L199: delegate ?: InputStreamReader( L200: source.inputStream(), L201: source.readBomAsCharset(charset),...

= valueEquivalence; L2889: this.concurrencyLevel = concurrencyLevel; L2890: this.delegate = delegate; L2891: } L2892: L2893: @Override L2894: protected ConcurrentMap<K, V> delegate() { L2895: return delegate; L2896: } L2897: L2898: void writeMapTo(ObjectOutputStream out) throws IOException { L2899: out.writeInt(delegate.size()); L2900: for (Entry<K, V> entry : delegate.entrySet()) { L2901: out.writeObject(entry.getKey()); L2902: out.writeObjec...