- Sort Score
- Num 10 results
- Language All
Results 161 - 170 of 598 for readOp (0.1 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/s3select/select.go
return rsc.offset, errors.New("seek past end of object") } if rsc.reader != nil { _ = rsc.reader.Close() rsc.reader = nil } return rsc.offset, nil } // Read call to implement io.Reader func (rsc *ObjectReadSeekCloser) Read(p []byte) (n int, err error) { if rsc.reader == nil { rsc.reader, err = rsc.segmentReader(rsc.offset) if err != nil { return 0, err } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 21.2K bytes - Click Count (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerAdapter.kt
* If this does read a value, it starts with the tag and length, and reads an entire value, * including any potential composed values. * * If there's nothing to read and no default value, this will throw an exception. */ fun fromDer(reader: DerReader): T fun fromDer(byteString: ByteString): T { val buffer = Buffer().write(byteString) val reader = DerReader(buffer) return fromDer(reader) } /**
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 4.2K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/io/ModelReader.java
* @throws ModelParseException If the input format could not be parsed. */ Model read(File input, Map<String, ?> options) throws IOException, ModelParseException; /** * Reads the model from the specified character reader. The reader will be automatically closed before the method * returns. * * @param input The reader to deserialize the model from, must not be {@code null}.Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Feb 25 08:27:34 GMT 2025 - 3.6K bytes - Click Count (0) -
internal/crypto/key_test.go
package crypto import ( "bytes" "crypto/rand" "encoding/hex" "io" "testing" "github.com/minio/minio/internal/logger" ) var shortRandom = func(limit int64) io.Reader { return io.LimitReader(rand.Reader, limit) } func recoverTest(i int, shouldPass bool, t *testing.T) { if err := recover(); err == nil && !shouldPass { t.Errorf("Test %d should fail but passed successfully", i)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jul 12 20:51:54 GMT 2024 - 6.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2Test.kt
class Http2Test { val frame = Buffer() val reader = Http2Reader(frame, false) val expectedStreamId = 15 @Test fun unknownFrameTypeSkipped() { writeMedium(frame, 4) // has a 4-byte field frame.writeByte(99) // type 99 frame.writeByte(FLAG_NONE) frame.writeInt(expectedStreamId) frame.writeInt(111111111) // custom dataCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 28.1K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/io/DefaultModelReader.java
return (InputSource) value; } private Model read(Reader reader, boolean strict, InputSource source) throws IOException { try { if (source != null) { return new MavenXpp3ReaderEx().read(reader, strict, source); } else { return new MavenXpp3Reader().read(reader, strict); } } catch (XmlPullParserException e) {
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jan 10 07:09:12 GMT 2025 - 3.4K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/io/ByteSourceAsCharSourceReadBenchmark.java
} }, USING_CHARSTREAMS_COPY { @Override String read(ByteSource byteSource, Charset cs) throws IOException { StringBuilder sb = new StringBuilder(); try (InputStreamReader reader = new InputStreamReader(byteSource.openStream(), cs)) { CharStreams.copy(reader, sb); } return sb.toString(); } },Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 5.2K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/io/ByteSourceAsCharSourceReadBenchmark.java
} }, USING_CHARSTREAMS_COPY { @Override String read(ByteSource byteSource, Charset cs) throws IOException { StringBuilder sb = new StringBuilder(); try (InputStreamReader reader = new InputStreamReader(byteSource.openStream(), cs)) { CharStreams.copy(reader, sb); } return sb.toString(); } },Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 5.2K bytes - Click Count (0) -
android/guava/src/com/google/common/io/Closeables.java
* flush all bytes to the underlying resource. * * @param reader the reader to be closed, or {@code null} in which case this method does nothing * @since 17.0 */ public static void closeQuietly(@Nullable Reader reader) { try { close(reader, true); } catch (IOException impossible) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 5.1K bytes - Click Count (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/classanalysis/AnalyzeAndShade.kt
"" } val reader = ClassReader(Files.newInputStream(file)) val details = classes[reader.className] details.visited = true val classWriter = ClassWriter(0) reader.accept( ClassRemapper( classWriter,Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Sat Mar 22 03:48:38 GMT 2025 - 7.3K bytes - Click Count (0)