Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 161 - 170 of 598 for readOp (0.1 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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 data
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 28.1K bytes
    - Click Count (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top