if (x * i == n) return factor(x) + " × " + i; L72: } L73: return Integer.toString(n); L74: } L75: }; L76: L77: thread.start(); L78: } L79: L80: /** L81: * This request body makes it possible for another thread to stream data to the uploading request. L82: * This is potentially useful for posting live event streams like video capture. Callers should L83: * write to {@code sink()} and close it to complete the post. L84: */ L85: static final class PipeBody extends...

the "top" {@code k} elements added to it, relative to a provided L39: * comparator. "Top" can mean the greatest or the lowest elements, specified in the factory used to L40: * create the {@code TopKSelector} instance. L41: * L42: * <p>If your input data is available as an {@link Iterable} or {@link Iterator}, prefer {@link L43: * Ordering#leastOf(Iterable, int)}, which provides the same implementation with an interface L44: * tailored to that use case. L45: * L46: * <p>This uses the same efficient...

NO EVENT SHALL THE COPYRIGHT L23:OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, L24:SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT L25:LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, L26:DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY L27:THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT L28:(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE L29:OF THIS SOFTWARE, EVEN IF ADVISED...

hpackWriter.writeHeaders(case.headersList) L52: newCases += case.copy(wire = bytesOut.readByteString()) L53: } L54: L55: testDecoder(story.copy(cases = newCases)) L56: } L57: L58: companion object { L59: private val RAW_DATA = arrayOf("raw-data") L60: } L61:}...

byte[] bytez = new byte[size]; L167: Arrays.fill(bytez, (byte) 0x99); L168: return bytez; L169: } L170: L171: public void testToString() { L172: byte[] data = new byte[] {127, -128, 5, -1, 14}; L173: assertEquals("7f8005ff0e", HashCode.fromBytes(data).toString()); L174: assertEquals("7f8005ff0e", base16().lowerCase().encode(data)); L175: } L176: L177: public void testHashCode_nulls() throws Exception { L178: sanityTester().testNulls(); L179: } L180: L181: public void testHashC...

all further attempts fail. L104: * L105: * The two values are independent: results can contain both (recoverable error), neither L106: * (success), just an exception (permanent failure), or just a plan (non-exceptional retry). L107: */ L108: data class ConnectResult( L109: val plan: Plan, L110: val nextPlan: Plan? = null, L111: val throwable: Throwable? = null, L112: ) { L113: val isSuccess: Boolean L114: get() = nextPlan == null && throwable == null L115: } L116:}...

L18: L19:import com.google.common.annotations.Beta; L20:import com.google.errorprone.annotations.DoNotMock; L21: L22:/** L23: * A functional interface for <a L24: * href="https://en.wikipedia.org/wiki/Graph_(discrete_mathematics)">graph</a>-structured data. L25: * L26: * <p>This interface is meant to be used as the type of a parameter to graph algorithms (such as L27: * breadth first traversal) that only need a way of accessing the successors of a node in a graph. L28: * L29: * <h3>Usage</h3> L30: *...

* while {@code ImmutableSortedSet.of(s)} returns an {@code ImmutableSortedSet<Set<String>>} L204: * containing one element (the given set itself). L205: * L206: * <p>Despite the method name, this method attempts to avoid actually copying the data when it is L207: * safe to do so. The exact circumstances under which a copy will or will not be performed are L208: * undocumented and subject to change. L209: * L210: * <p>This method is not type-safe, as it may be called on elements that...

L17:package com.google.common.collect.testing.google; L18: L19:import com.google.common.annotations.GwtCompatible; L20:import com.google.common.collect.SetMultimap; L21: L22:/** L23: * A generator for {@code SetMultimap} implementations based on test data. L24: * L25: * @author Louis Wasserman L26: */ L27:@GwtCompatible L28:public interface TestSetMultimapGenerator<K, V> L29: extends TestMultimapGenerator<K, V, SetMultimap<K, V>> {}...

elements) L238: : copyOf(elements.iterator()); L239: } L240: L241: /** L242: * Returns an immutable list containing the given elements, in order. L243: * L244: * <p>Despite the method name, this method attempts to avoid actually copying the data when it is L245: * safe to do so. The exact circumstances under which a copy will or will not be performed are L246: * undocumented and subject to change. L247: * L248: * <p>Note that if {@code list} is a {@code List<String>}, then {@code ...