return delegate!!.inputStream L136: } L137: L138: @Throws(SocketException::class) L139: override fun getKeepAlive(): Boolean { L140: return delegate!!.keepAlive L141: } L142: L143: override fun getLocalAddress(): InetAddress { L144: return delegate!!.localAddress L145: } L146: L147: override fun getLocalPort(): Int { L148: return delegate!!.localPort L149: } L150: L151: @Throws(IOException::class) L152: override fun getOutputStream(): OutputStream { L153: return delegate!!.outputStream...

subclasses. */ L43: protected ForwardingListMultimap() {} L44: L45: @Override L46: protected abstract ListMultimap<K, V> delegate(); L47: L48: @Override L49: public List<V> get(@ParametricNullness K key) { L50: return delegate().get(key); L51: } L52: L53: @CanIgnoreReturnValue L54: @Override L55: public List<V> removeAll(@CheckForNull Object key) { L56: return delegate().removeAll(key); L57: } L58: L59: @CanIgnoreReturnValue L60: @Override L61: public List<V> replaceValues(@ParametricNullness...

FileBackedOutputStream(0, true); L35: L36: write(out, data, 0, 100, true); L37: final File file = out.getFile(); L38: assertEquals(100, file.length()); L39: assertTrue(file.exists()); L40: out.close(); L41: L42: // Make sure that finalize deletes the file L43: out = null; L44: L45: // times out and throws RuntimeException on failure L46: GcFinalization.awaitDone( L47: new GcFinalization.FinalizationPredicate() { L48: @Override L49: public boolean isDone()...

available on Android until version 7 L32: * (API level 24). L33: */ L34:@IgnoreJRERequirement L35:internal class InsecureExtendedTrustManager( L36: private val delegate: X509ExtendedTrustManager, L37: private val insecureHosts: List<String>, L38:) : X509ExtendedTrustManager() { L39: override fun getAcceptedIssuers(): Array<X509Certificate> = delegate.acceptedIssuers L40: L41: override fun checkServerTrusted( L42: chain: Array<out X509Certificate>, L43: authType: String, L44: socket: Socket,...

L166: return new Builder<B>().putAll(map).build(); L167: } L168: L169: private final ImmutableMap<Class<? extends B>, B> delegate; L170: L171: private ImmutableClassToInstanceMap(ImmutableMap<Class<? extends B>, B> delegate) { L172: this.delegate = delegate; L173: } L174: L175: @Override L176: protected Map<Class<? extends B>, B> delegate() { L177: return delegate; L178: } L179: L180: @Override L181: @SuppressWarnings("unchecked") // value could not get in if not a T L182: @CheckForNull...

DELEGATE_METHOD = ForwardingObject.class.getDeclaredMethod("delegate"); L42: DELEGATE_METHOD.setAccessible(true); L43: } catch (SecurityException e) { L44: throw new RuntimeException(e); L45: } catch (NoSuchMethodException e) { L46: throw new AssertionError(e); L47: } L48: } L49: L50: /** L51: * Ensures that all interface methods of {@code forwarderClass} are forwarded to the {@link L52: * ForwardingObject#delegate}. {@code forwarderClass} is assumed to only implement one...

get() { L50: before() // This implicitly starts the delegate. L51: return delegate.port L52: } L53: L54: val hostName: String L55: get() { L56: before() // This implicitly starts the delegate. L57: return delegate.hostName L58: } L59: L60: var protocolNegotiationEnabled: Boolean by delegate::protocolNegotiationEnabled L61: L62: @get:JvmName("protocols") L63: var protocols: List<Protocol> L64: get() = delegate.protocols L65: set(value) { L66: delegate.protocols...

submittingTaskQueue.nextTask = task; L358: // requireNonNull(delegate) is safe for reasons similar to requireNonNull(sequencer). L359: submittingTaskQueue.nextExecutor = requireNonNull(delegate); L360: delegate = null; L361: } else { L362: // requireNonNull(delegate) is safe for reasons similar to requireNonNull(sequencer). L363: Executor localDelegate = requireNonNull(delegate); L364: delegate = null; L365: this.task = task; L366: ...

} L42: L43: override fun invalidate() { L44: delegate!!.invalidate() L45: } L46: L47: override fun isValid(): Boolean { L48: return delegate!!.isValid L49: } L50: L51: override fun putValue( L52: s: String, L53: o: Any, L54: ) { L55: delegate!!.putValue(s, o) L56: } L57: L58: override fun getValue(s: String): Any { L59: return delegate!!.getValue(s) L60: } L61: L62: override fun removeValue(s: String) { L63: delegate!!.removeValue(s) L64: } L65: L66: override fun...

logWithTime("connectStart: $inetSocketAddress $proxy") L85: L86: delegate.connectStart(call, inetSocketAddress, proxy) L87: } L88: L89: override fun secureConnectStart(call: Call) { L90: logWithTime("secureConnectStart") L91: L92: delegate.secureConnectStart(call) L93: } L94: L95: override fun secureConnectEnd( L96: call: Call, L97: handshake: Handshake?, L98: ) { L99: logWithTime("secureConnectEnd: $handshake") L100: L101: delegate.secureConnectEnd(call, handshake) L102: } L103: L104:...