- Sort Score
- Num 10 results
- Language All
Results 131 - 140 of 1,804 for readn (0.04 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt
* [Call.request] is a redirect to a different address. * * Prior to OkHttp 4.3 this was incorrectly invoked when the client was ready to read headers. * This was misleading for tracing because it was too early. */ open fun responseHeadersStart(call: Call) { } /** * Invoked immediately after receiving response headers. *
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 21:03:04 GMT 2025 - 24.9K bytes - Click Count (0) -
guava/src/com/google/common/collect/AbstractIterator.java
switch (state) { case DONE: return false; case READY: return true; default: } return tryToComputeNext(); } private boolean tryToComputeNext() { state = State.FAILED; // temporary pessimism next = computeNext(); if (state != State.DONE) { state = State.READY; return true; } return false; }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 6.3K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/LocalCache.java
* at table entries if it is 0. * * - All (synchronized) write operations should write to the "count" field after structurally * changing any bin. The operations must not take any action that could even momentarily cause a * concurrent read operation to see inconsistent data. This is made easier by the nature of theCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 143.5K bytes - Click Count (0) -
guava/src/com/google/common/base/Suppliers.java
public T get() { // Another variant of Double Checked Locking. // // We use two volatile reads. We could reduce this to one by // putting our fields into a holder class, but (at least on x86) // the extra memory consumption and indirection are more // expensive than the extra volatile reads. long nanos = expirationNanos; long now = System.nanoTime(); if (nanos == 0 || now - nanos >= 0) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 31 21:24:28 GMT 2026 - 16.1K bytes - Click Count (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
assertThat(inputStream.read()).isEqualTo('A'.code) assertThat(inputStream.read()).isEqualTo('B'.code) assertThat(inputStream.read()).isEqualTo('C'.code) assertThat(inputStream.read()).isEqualTo('D'.code) assertThat(inputStream.read()).isEqualTo('E'.code) assertThat(inputStream.read()).isEqualTo('F'.code) assertThat(inputStream.read()).isEqualTo(-1)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 03 13:16:34 GMT 2025 - 22.3K bytes - Click Count (0) -
guava/src/com/google/common/collect/HashMultimap.java
* views are modifiable. * * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent * read operations will work correctly if the last write <i>happens-before</i> any reads. To allow * concurrent update operations, wrap your multimap with a call to {@link * Multimaps#synchronizedSetMultimap}. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 05 23:15:58 GMT 2025 - 5.8K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
* look at table entries if it is 0. * * - All (synchronized) write operations should write to the "count" field after structurally * changing any bin. The operations must not take any action that could even momentarily * cause a concurrent read operation to see inconsistent data. This is made easier by theCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 89.9K bytes - Click Count (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/BasicDerAdapter.kt
result = 31 * result + defaultValue.hashCode() result = 31 * result + (if (typeHint) 1 else 0) return result } override fun toString(): String = "$name [$tagClass/$tag]" /** Reads and writes values without knowledge of the enclosing tag, length, or defaults. */ interface Codec<T> { fun decode(reader: DerReader): T fun encode( writer: DerWriter, value: T, )
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.4K bytes - Click Count (0) -
android/guava/src/com/google/common/hash/AbstractNonStreamingHashFunction.java
this.buffer = ByteBuffer.allocate(expectedInputSize).order(ByteOrder.LITTLE_ENDIAN); } /** * Resizes the buffer if necessary. Guaranteed to leave `buffer` in Write Mode ready for new * data. */ private void ensureCapacity(int needed) { if (buffer.remaining() >= needed) { return; } int currentCapacity = buffer.capacity();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Dec 04 15:39:10 GMT 2025 - 4.8K bytes - Click Count (0) -
android/guava/src/com/google/common/base/Stopwatch.java
*/ @CanIgnoreReturnValue public Stopwatch start() { checkState(!isRunning, "This stopwatch is already running."); isRunning = true; startTick = ticker.read(); return this; } /** * Stops the stopwatch. Future reads will return the fixed duration that had elapsed up to this * point. * * @return this {@code Stopwatch} instance
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Oct 08 18:55:33 GMT 2025 - 9.5K bytes - Click Count (0)