Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 1,736 for read (0.03 sec)

  1. internal/s3select/csv/recordtransform.go

    	recordDelimiter []byte
    	oneByte         []byte
    	useOneByte      bool
    }
    
    func (rr *recordTransform) Read(p []byte) (n int, err error) {
    	if rr.useOneByte {
    		p[0] = rr.oneByte[0]
    		rr.useOneByte = false
    		n, err = rr.reader.Read(p[1:])
    		n++
    	} else {
    		n, err = rr.reader.Read(p)
    	}
    
    	if err != nil {
    		return n, err
    	}
    
    	// Do nothing if record-delimiter is already newline.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  2. impl/maven-core/src/main/java/org/apache/maven/artifact/repository/metadata/io/DefaultMetadataReader.java

    @Named
    @Singleton
    public class DefaultMetadataReader implements MetadataReader {
    
        public Metadata read(File input, Map<String, ?> options) throws IOException {
            Objects.requireNonNull(input, "input cannot be null");
    
            return read(Files.newInputStream(input.toPath()), options);
        }
    
        public Metadata read(Reader input, Map<String, ?> options) throws IOException {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/io/CharSourceTest.java

        assertTrue(source.wasStreamOpened());
        assertFalse(source.wasStreamClosed());
    
        StringWriter writer = new StringWriter();
        char[] buf = new char[64];
        int read;
        while ((read = reader.read(buf)) != -1) {
          writer.write(buf, 0, read);
        }
        reader.close();
        writer.close();
    
        assertTrue(source.wasStreamClosed());
        assertEquals(STRING, writer.toString());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  4. src/archive/tar/reader.go

    		sparseMap = sparseMap[2:]
    	}
    	return spd, nil
    }
    
    // Read reads from the current file in the tar archive.
    // It returns (0, io.EOF) when it reaches the end of that file,
    // until [Next] is called to advance to the next file.
    //
    // If the current file is sparse, then the regions marked as a hole
    // are read back as NUL-bytes.
    //
    // Calling Read on special types like [TypeLink], [TypeSymlink], [TypeChar],
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  5. impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultPluginXmlFactory.java

                if (inputStream != null) {
                    return xml.read(inputStream, request.isStrict());
                } else if (reader != null) {
                    return xml.read(reader, request.isStrict());
                } else if (path != null) {
                    try (InputStream is = Files.newInputStream(path)) {
                        return xml.read(is, request.isStrict());
                    }
                } else {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

     * atomic: a read observes the full set of values as they were before or after the commit, but never
     * a mix of values.
     *
     * Clients call [get] to read a snapshot of an entry. The read will observe the value at the time
     * that [get] was called. Updates and removals after the call do not impact ongoing reads.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/Request.kt

        /**
         * Attaches [tag] to the request using [T] as a key. Tags can be read from a request using
         * [Request.tag]. Use null to remove any existing tag assigned for [T].
         *
         * Use this API to attach timing, debugging, or other application data to a request so that
         * you may read it in interceptors, event listeners, or callbacks.
         */
        @JvmName("reifiedTag")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:17:44 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/UppercaseResponseInterceptor.kt

          @Throws(IOException::class)
          override fun read(
            sink: Buffer,
            byteCount: Long,
          ): Long {
            val buffer = Buffer()
            val read = delegate.read(buffer, byteCount)
            if (read != -1L) {
              sink.write(buffer.readByteString().toAsciiUppercase())
            }
            return read
          }
        }
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  9. guava/src/com/google/common/io/CharSource.java

     *       block indefinitely or fail if the source creates an infinite reader.
     *   <li><b>Non-destructive:</b> A <i>destructive</i> reader will consume or otherwise alter the
     *       source as they are read from it. A source that provides such readers will not be reusable,
     *       and operations that read from the stream (including {@link #length()}, in some
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  10. internal/etag/reader.go

    	n, err := r.src.Read(p)
    	r.readN += int64(n)
    	r.md5.Write(p[:n])
    
    	if err == io.EOF && len(r.checksum) != 0 {
    		if etag := r.ETag(); !Equal(etag, r.checksum) {
    			return n, VerifyError{
    				Expected: r.checksum,
    				Computed: etag,
    			}
    		}
    	}
    	return n, err
    }
    
    // ETag returns the ETag of all the content read
    // so far. Reading more content changes the MD5
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 4.8K bytes
    - Viewed (0)
Back to top