This extends [X509TrustManager] for Android to disable verification for a set of hosts. */ L26:internal class InsecureAndroidTrustManager( L27: private val delegate: X509TrustManager, L28: private val insecureHosts: List<String>, L29:) : X509TrustManager { L30: private val checkServerTrustedMethod: Method? = L31: try { L32: delegate::class.java.getMethod( L33: "checkServerTrusted", L34: Array<X509Certificate>::class.java, L35: String::class.java, L36: String::class.java,...

Don't mock. L333: public void testListeningDecorator_noWrapExecuteTask() { L334: ExecutorService delegate = mock(ExecutorService.class); L335: ListeningExecutorService service = listeningDecorator(delegate); L336: Runnable task = L337: new Runnable() { L338: @Override L339: public void run() {} L340: }; L341: service.execute(task); L342: verify(delegate).execute(task); L343: } L344: L345: public void testListeningDecorator_scheduleSuccess() throws Exception...

extends ReserializingTestCollectionGenerator<E> L31: implements TestSetGenerator<E> { L32: L33: ReserializingTestSetGenerator(TestSetGenerator<E> delegate) { L34: super(delegate); L35: } L36: L37: public static <E> TestSetGenerator<E> newInstance(TestSetGenerator<E> delegate) { L38: return new ReserializingTestSetGenerator<>(delegate); L39: } L40: L41: @Override L42: public Set<E> create(Object... elements) { L43: return (Set<E>) super.create(elements); L44: } L45:}...

WeakSafeLock extends ForwardingLock { L307: private final Lock delegate; L308: L309: @SuppressWarnings("unused") L310: private final WeakSafeReadWriteLock strongReference; L311: L312: WeakSafeLock(Lock delegate, WeakSafeReadWriteLock strongReference) { L313: this.delegate = delegate; L314: this.strongReference = strongReference; L315: } L316: L317: @Override L318: Lock delegate() { L319: return delegate; L320: } L321: L322: @Override L323: public Condition...

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

wrap(set1)) L234: .addEqualityGroup(set2, wrap(set2)) L235: .testEquals(); L236: } L237: L238: private static <T> NavigableSet<T> wrap(final NavigableSet<T> delegate) { L239: return new ForwardingNavigableSet<T>() { L240: @Override L241: protected NavigableSet<T> delegate() { L242: return delegate; L243: } L244: }; L245: } L246:}...

implements ListMultimap<K, V> { L791: UnmodifiableListMultimap(ListMultimap<K, V> delegate) { L792: super(delegate); L793: } L794: L795: @Override L796: public ListMultimap<K, V> delegate() { L797: return (ListMultimap<K, V>) super.delegate(); L798: } L799: L800: @Override L801: public List<V> get(@ParametricNullness K key) { L802: return Collections.unmodifiableList(delegate().get(key)); L803: } L804: L805: @Override L806: public List<V> removeAll(@CheckForNull...

extends ForwardingMap<K, V> implements Serializable { L48: public final Object mutex; L49: private Map<K, V> delegate; L50: L51: public TestMap(Map<K, V> delegate, Object mutex) { L52: checkNotNull(mutex); L53: this.delegate = delegate; L54: this.mutex = mutex; L55: } L56: L57: @Override L58: protected Map<K, V> delegate() { L59: return delegate; L60: } L61: L62: @Override L63: public int size() { L64: assertTrue(Thread.holdsLock(mutex)); L65: ...

L22:/** L23: * An SSLSocketFactory that delegates calls. Sockets created by the delegate are wrapped with ones L24: * that will not accept the [TLS_FALLBACK_SCSV] cipher, thus bypassing server-side fallback L25: * checks on platforms that support it. Unfortunately this wrapping will disable any L26: * reflection-based calls to SSLSocket from Platform. L27: */ L28:class FallbackTestClientSocketFactory( L29: delegate: SSLSocketFactory, L30:) : DelegatingSSLSocketFactory(delegate) { L31: override...

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