- Sort Score
- Num 10 results
- Language All
Results 201 - 210 of 864 for readOp (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
build-logic/documentation/src/main/groovy/gradlebuild/docs/ReleaseNotesTransformer.java
private File baseCss; private File releaseNotesCss; private File releaseNotesJavascript; public ReleaseNotesTransformer(Reader original) { super(original); this.in = new Reader() { Reader delegate = null; @Override public int read(char[] cbuf, int off, int len) throws IOException { if (delegate == null) { delegate = transform(original);Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Mar 03 01:59:51 GMT 2026 - 11.3K bytes - Click Count (0) -
android/guava/src/com/google/common/io/CharSequenceReader.java
import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import java.io.IOException; import java.io.Reader; import java.nio.CharBuffer; import org.jspecify.annotations.Nullable; /** * A {@link Reader} that reads the characters in a {@link CharSequence}. Like {@code StringReader}, * but works with any {@link CharSequence}. * * @author Colin Decker */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyJvmTest.kt
return hex.decodeHex().toResponseBody(mediaType) } fun exhaust(reader: Reader): String { val builder = StringBuilder() val buf = CharArray(10) var read: Int while (reader.read(buf).also { read = it } != -1) { builder.appendRange(buf, 0, read) } return builder.toString() } }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 12.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
} } int undrainedIndex = reads.size() - segment.recencyQueue.size(); checkAndDrainRecencyQueue(map, segment, reads.subList(undrainedIndex, reads.size())); readOrder.addAll(reads); checkEvictionQueues(map, segment, readOrder, writeOrder); checkExpirationTimes(map); } } public void testComputeExistingEntry() throws ExecutionException {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 114.9K bytes - Click Count (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
} } int undrainedIndex = reads.size() - segment.recencyQueue.size(); checkAndDrainRecencyQueue(map, segment, reads.subList(undrainedIndex, reads.size())); readOrder.addAll(reads); checkEvictionQueues(map, segment, readOrder, writeOrder); checkExpirationTimes(map); } } public void testComputeExistingEntry() throws ExecutionException {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 116.4K bytes - Click Count (0) -
cmd/postpolicyform.go
} // parsePostPolicyForm - Parse JSON policy string into typed PostPolicyForm structure. func parsePostPolicyForm(r io.Reader) (PostPolicyForm, error) { reader, err := sanitizePolicy(r) if err != nil { return PostPolicyForm{}, err } d := json.NewDecoder(reader) // Convert po into interfaces and // perform strict type conversion using reflection. var rawPolicy struct {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Oct 23 15:10:12 GMT 2025 - 12.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/TestCharSource.java
* limitations under the License. */ package com.google.common.io; import static java.nio.charset.StandardCharsets.UTF_8; import java.io.IOException; import java.io.InputStreamReader; import java.io.Reader; import org.jspecify.annotations.NullUnmarked; /** * A char source for testing that has configurable options. * * @author Colin Decker */ @NullUnmarked
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 1.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt
try { reader!!.processNextFrame() receivedCloseCode == -1 } catch (e: Exception) { failWebSocket(e = e) false } /** * Clean up and publish necessary close events when the reader is done. Invoked only by the reader * thread. */ fun finishReader() { val code: Int val reason: String? val sendOnClosed: BooleanCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 21.6K bytes - Click Count (0) -
docs/bucket/replication/delete-replication.sh
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 09:42:21 GMT 2024 - 3.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt
Header("via", ""), Header("www-authenticate", ""), ) val NAME_TO_FIRST_INDEX = nameToFirstIndex() // http://tools.ietf.org/html/draft-ietf-httpbis-header-compression-12#section-3.1 class Reader @JvmOverloads constructor( source: Source, private val headerTableSizeSetting: Int, private var maxDynamicTableByteCount: Int = headerTableSizeSetting, ) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 23.2K bytes - Click Count (0)