- Sort Score
- Num 10 results
- Language All
Results 251 - 260 of 864 for readOp (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
benchmarks/src/main/java/org/elasticsearch/benchmark/script/ScriptScoreBenchmark.java
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Mon Sep 20 13:45:50 GMT 2021 - 8.1K bytes - Click Count (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt
// Replace the body with a stripped one so the callbacks can't see real data. val response = response.stripBody() val reader = ServerSentEventReader(body.source(), this) try { if (!canceled) { listener.onOpen(this, response) while (!canceled && reader.processNextEvent()) { } } } catch (e: Exception) { val exception = when {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Oct 03 07:51:20 GMT 2025 - 3.2K bytes - Click Count (0) -
src/test/java/org/codelibs/core/collection/IndexedIteratorTest.java
} } /** * @throws Exception */ @Test public void testForEachLineIterator() throws Exception { final StringReader reader = new StringReader("aaa\nbbb\nccc\n"); for (final Indexed<String> indexed : indexed(iterable(reader))) { System.out.println(indexed.getIndex()); System.out.println(indexed.getElement()); } }Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Sat May 10 01:32:17 GMT 2025 - 2.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/SourceSinkFactories.java
} @Override public String getSinkContents() throws IOException { File file = getFile(); Reader reader = new InputStreamReader(new FileInputStream(file), UTF_8); StringBuilder builder = new StringBuilder(); CharBuffer buffer = CharBuffer.allocate(100); while (reader.read(buffer) != -1) { Java8Compatibility.flip(buffer); builder.append(buffer);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jul 16 17:42:14 GMT 2025 - 12.7K bytes - Click Count (0) -
docs/en/docs/tutorial/request-files.md
* `write(data)`: Writes `data` (`str` or `bytes`) to the file. * `read(size)`: Reads `size` (`int`) bytes/characters of the file. * `seek(offset)`: Goes to the byte position `offset` (`int`) in the file. * E.g., `await myfile.seek(0)` would go to the start of the file. * This is especially useful if you run `await myfile.read()` once and then need to read the contents again. * `close()`: Closes the file.Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 7K bytes - Click Count (0) -
src/main/java/jcifs/netbios/Lmhosts.java
result = this.table.get(name); } } catch (final IOException fnfe) { log.error("Could not read lmhosts " + tc.getConfig().getLmHostsFileName(), fnfe); //$NON-NLS-1$ } return result; } void populate(final Reader r, final CIFSContext tc) throws IOException { String line; final BufferedReader br = new BufferedReader(r);
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 6.3K bytes - Click Count (0) -
build-conventions/src/main/java/org/elasticsearch/gradle/internal/conventions/precommit/PomValidationTask.java
} @TaskAction public void checkPom() throws Exception { try (FileReader fileReader = new FileReader(pomFile.getAsFile().get())) { MavenXpp3Reader reader = new MavenXpp3Reader(); Model model = reader.read(fileReader); validateString("groupId", model.getGroupId()); validateString("artifactId", model.getArtifactId()); validateString("version", model.getVersion());Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 3.4K bytes - Click Count (0) -
src/main/java/jcifs/netbios/SessionServicePacket.java
return ((src[srcIndex++] & 0x01) << 16) + ((src[srcIndex++] & 0xFF) << 8) + (src[srcIndex++] & 0xFF); } static int readn(final InputStream in, final byte[] b, final int off, final int len) throws IOException { int i = 0, n; while (i < len) { n = in.read(b, off + i, len - i); if (n <= 0) { break; } i += n; }
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 5.2K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/MultipartReaderTest.kt
body.writeTo(bodyContent) val reader = MultipartReader(bodyContent, "boundary") val quickPart = reader.nextPart()!! assertThat(quickPart.headers).isEqualTo( headersOf( "Content-Type", "text/plain; charset=utf-8", ), ) assertThat(quickPart.body.readUtf8()).isEqualTo("Quick") val brownPart = reader.nextPart()!! assertThat(brownPart.headers).isEqualTo(
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed May 28 02:11:14 GMT 2025 - 15.4K bytes - Click Count (0) -
CHANGELOG.md
CHANGELOG/README.md...
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Thu Jan 05 07:53:04 GMT 2023 - 19 bytes - Click Count (0)