issions()).containsExactly(OWNER_READ, OWNER_WRITE); L88: } L89: } L90: out.close(); L91: L92: // Check that source returns the right data L93: assertTrue(Arrays.equals(data, source.read())); L94: L95: // Make sure that reset deleted the file L96: out.reset(); L97: if (file != null) { L98: assertFalse(file.exists()); L99: } L100: } L101: L102: L103: public void testThreshold_resetOnFinalize() throws Exception { L104: testThreshold(0, 100, true, true); L105:...

L28:@GwtCompatible L29:public class BaseComparable implements Comparable<BaseComparable>, Serializable { L30: private final String s; L31: L32: public BaseComparable(String s) { L33: this.s = s; L34: } L35: L36: @Override L37: public int hashCode() { // delegate to 's' L38: return s.hashCode(); L39: } L40: L41: @Override L42: public boolean equals(@Nullable Object other) { L43: if (other == null) { L44: return false; L45: } else if (other instanceof BaseComparable) { L46: return s....

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

public static <K, V> ImmutableBiMap<K, V> copyOf( L248: Iterable<? extends Entry<? extends K, ? extends V>> entries) { L249: return new Builder<K, V>().putAll(entries).build(); L250: } L251: L252: ImmutableBiMap(Map<K, V> delegate) { L253: super(delegate); L254: } L255: L256: public abstract ImmutableBiMap<V, K> inverse(); L257: L258: @Override L259: public ImmutableSet<V> values() { L260: return inverse().keySet(); L261: } L262: L263: @CheckForNull L264: public final V forcePut(K...

client = L43: OkHttpClient.Builder() L44: .build() L45: L46: @Test L47: fun getWithCustomSocketFactory() { L48: assumeTrue(Build.VERSION.SDK_INT >= 24) L49: L50: class CustomSSLSocketFactory( L51: delegate: SSLSocketFactory, L52: ) : DelegatingSSLSocketFactory(delegate) { L53: override fun configureSocket(sslSocket: SSLSocket): SSLSocket { L54: if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.N) { L55: val parameters = sslSocket.sslParameters L56: val...

with the properties specified in {@code builder}. */ L36: StandardMutableGraph(AbstractGraphBuilder<? super N> builder) { L37: this.backingValueGraph = new StandardMutableValueGraph<>(builder); L38: } L39: L40: @Override L41: BaseGraph<N> delegate() { L42: return backingValueGraph; L43: } L44: L45: @Override L46: public boolean addNode(N node) { L47: return backingValueGraph.addNode(node); L48: } L49: L50: @Override L51: public boolean putEdge(N nodeU, N nodeV) { L52: return...

Strings.padEnd("x", -1, '-')); L97: } L98: L99: public void testPadEnd_null() { L100: assertThrows(NullPointerException.class, () -> Strings.padEnd(null, 5, '0')); L101: } L102: L103: @SuppressWarnings("InlineMeInliner") // test of method that doesn't just delegate L104: public void testRepeat() { L105: String input = "20"; L106: assertEquals("", Strings.repeat(input, 0)); L107: assertEquals("20", Strings.repeat(input, 1)); L108: assertEquals("2020", Strings.repeat(input, 2)); L109: assertEquals("202020",...

new TestStringSortedSetGenerator() { L313: @Override L314: public SortedSet<String> create(String[] elements) { L315: NavigableSet<String> delegate = new TreeSet<>(MinimalCollection.of(elements)); L316: return Collections.synchronizedNavigableSet(delegate); L317: } L318: }) L319: .named("synchronizedNavigableSet/TreeSet, natural") L320: .withFeatures( L321: SetFeature.GENERAL_PURPOSE, L322:...

IOException { L60: out.write(b); L61: count++; L62: } L63: L64: // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior: L65: // it silently ignores any exception thrown by flush(). Instead, just close the delegate stream. L66: // It should flush itself if necessary. L67: @Override L68: public void close() throws IOException { L69: out.close(); L70: } L71:}...

(omits zlib header): L38: true, L39: ) L40: L41: private val deflaterSink = DeflaterSink(deflatedBytes, deflater) L42: L43: /** Deflates [buffer] in place as described in RFC 7692 section 7.2.1. */ L44: @Throws(IOException::class) L45: fun deflate(buffer: Buffer) { L46: require(deflatedBytes.size == 0L) L47: L48: if (noContextTakeover) { L49: deflater.reset() L50: } L51: L52: deflaterSink.write(buffer, buffer.size) L53: deflaterSink.flush() L54: L55: if (deflatedByte...