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

carrier.noNewExchanges() L252: return UnknownLengthSource() L253: } L254: L255: /** L256: * Sets the delegate of `timeout` to [Timeout.NONE] and resets its underlying timeout L257: * to the default configuration. Use this to avoid unexpected sharing of timeouts between pooled L258: * connections. L259: */ L260: private fun detachTimeout(timeout: ForwardingTimeout) { L261: val oldDelegate = timeout.delegate L262: timeout.setDelegate(Timeout.NONE) L263: oldDelegate.clearDeadline() L264: o...

L165: L166: Supplier<Integer> copy = reserialize(memoizedSupplier); L167: Object unused2 = memoizedSupplier.get(); L168: L169: CountingSupplier countingCopy = L170: (CountingSupplier) ((Suppliers.MemoizingSupplier<Integer>) copy).delegate; L171: checkMemoize(countingCopy, copy); L172: } L173: L174: public void testCompose() { L175: Supplier<Integer> fiveSupplier = L176: new Supplier<Integer>() { L177: @Override L178: public Integer get() { L179: ...

L165: L166: Supplier<Integer> copy = reserialize(memoizedSupplier); L167: Object unused2 = memoizedSupplier.get(); L168: L169: CountingSupplier countingCopy = L170: (CountingSupplier) ((Suppliers.MemoizingSupplier<Integer>) copy).delegate; L171: checkMemoize(countingCopy, copy); L172: } L173: L174: public void testCompose() { L175: Supplier<Integer> fiveSupplier = L176: new Supplier<Integer>() { L177: @Override L178: public Integer get() { L179: ...

HashCode hash() { L67: return hasher.hash(); L68: } L69: L70: // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior: L71: // it silently ignores any exception thrown by flush(). Instead, just close the delegate stream. L72: // It should flush itself if necessary. L73: @Override L74: public void close() throws IOException { L75: out.close(); L76: } L77:}...

L86: @Override L87: public SortedMultiset<E> tailMultiset(E fromElement, BoundType boundType) { L88: return forwardMultiset().headMultiset(fromElement, boundType).descendingMultiset(); L89: } L90: L91: @Override L92: protected Multiset<E> delegate() { L93: return forwardMultiset(); L94: } L95: L96: @Override L97: public SortedMultiset<E> descendingMultiset() { L98: return forwardMultiset(); L99: } L100: L101: @Override L102: @CheckForNull L103: public Entry<E> firstEntry() { L104:...

values. This is useful for testing methods that must treat the return value from L356: * size() as a hint only. L357: * L358: * @param delta the difference between the true size of the collection and the values returned by L359: * the size method L360: */ L361: public static <T extends @Nullable Object> Collection<T> misleadingSizeCollection(int delta) { L362: // It would be nice to be able to return a real concurrent L363: // collection like ConcurrentLinkedQueue, so that e.g. concurrent...

public SortedMultiset<E> tailMultiset(@ParametricNullness E fromElement, BoundType boundType) { L93: return forwardMultiset().headMultiset(fromElement, boundType).descendingMultiset(); L94: } L95: L96: @Override L97: protected Multiset<E> delegate() { L98: return forwardMultiset(); L99: } L100: L101: @Override L102: public SortedMultiset<E> descendingMultiset() { L103: return forwardMultiset(); L104: } L105: L106: @Override L107: @CheckForNull L108: public Entry<E> firstEntry()...

{ L210: val call = RealCall(client, Request(address.url), forWebSocket = false) L211: val chain = newChain(call) L212: return RealRoutePlanner( L213: taskRunner = client.taskRunner, L214: connectionPool = client.connectionPool.delegate, L215: readTimeoutMillis = client.readTimeoutMillis, L216: writeTimeoutMillis = client.writeTimeoutMillis, L217: socketConnectTimeoutMillis = chain.connectTimeoutMillis, L218: socketReadTimeoutMillis = chain.readTimeoutMillis,...

L82: MinMaxPriorityQueue<T> mmHeap; L83: L84: public InvertedMinMaxPriorityQueue(Comparator<T> comparator) { L85: mmHeap = MinMaxPriorityQueue.orderedBy(comparator).create(); L86: } L87: L88: @Override L89: protected Queue<T> delegate() { L90: return mmHeap; L91: } L92: L93: @Override L94: public @Nullable T poll() { L95: return mmHeap.pollLast(); L96: } L97: } L98: L99: public enum HeapType { L100: MIN_MAX { L101: @Override L102: public Queue<Integer>...