Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 1,736 for read (0.02 sec)

  1. guava/src/com/google/common/io/CountingInputStream.java

      }
    
      /** Returns the number of bytes read. */
      public long getCount() {
        return count;
      }
    
      @Override
      public int read() throws IOException {
        int result = in.read();
        if (result != -1) {
          count++;
        }
        return result;
      }
    
      @Override
      public int read(byte[] b, int off, int len) throws IOException {
        int result = in.read(b, off, len);
        if (result != -1) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

        Reader reader = new StringReader(testString);
    
        assertEquals(testString.charAt(0), reader.read());
        CharStreams.skipFully(reader, 1);
        assertEquals(testString.charAt(2), reader.read());
        CharStreams.skipFully(reader, 2);
        assertEquals(testString.charAt(5), reader.read());
    
        assertEquals(-1, reader.read());
      }
    
      public void testAsWriter() {
        // Should wrap Appendable in a new object
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/io/CharStreamsTest.java

        Reader reader = new StringReader(testString);
    
        assertEquals(testString.charAt(0), reader.read());
        CharStreams.skipFully(reader, 1);
        assertEquals(testString.charAt(2), reader.read());
        CharStreams.skipFully(reader, 2);
        assertEquals(testString.charAt(5), reader.read());
    
        assertEquals(-1, reader.read());
      }
    
      public void testAsWriter() {
        // Should wrap Appendable in a new object
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  4. src/test/java/jcifs/tests/RandomAccessFileTest.java

                int rs = Math.min(bufSize, (int) ( length - p ));
                int read = is.read(buffer, 0, rs);
                if ( read < 0 ) {
                    fail("Unexpected EOF");
                }
    
                byte verify[] = new byte[read];
                ReadWriteTest.randBytes(r, verify);
                byte actual[] = Arrays.copyOfRange(buffer, 0, read);
    
                assertArrayEquals("Data matches at offset " + p, actual, verify);
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 11.4K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

            sourcePos += bytesToRead
            return bytesToRead
          }
    
          // Read from upstream. This always reads a full buffer: that might be more than what the
          // current call to Source.read() has requested.
          try {
            val upstreamBytesRead = upstream!!.read(upstreamBuffer, bufferMaxSize)
    
            // If we've exhausted upstream, we're done.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  6. guava/src/com/google/common/io/ByteStreams.java

        byte[] buf = createBuffer();
        int read;
        do {
          read = input.read(buf);
        } while (read != -1 && processor.processBytes(buf, 0, read));
        return processor.getResult();
      }
    
      /**
       * Reads some bytes from an input stream and stores them into the buffer array {@code b}. This
       * method blocks until {@code len} bytes of input data have been read into the array, or end of
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 29.7K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/io/CharSourceTester.java

      public void testOpenStream() throws IOException {
        Reader reader = source.openStream();
    
        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();
    
        assertExpectedString(writer.toString());
      }
    
      public void testOpenBufferedStream() throws IOException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  8. internal/bucket/bandwidth/reader.go

    type MonitorReaderOptions struct {
    	BucketOptions
    	HeaderSize int
    }
    
    // Read implements a throttled read
    func (r *MonitoredReader) Read(buf []byte) (n int, err error) {
    	if r.throttle == nil {
    		return r.r.Read(buf)
    	}
    	if r.lastErr != nil {
    		err = r.lastErr
    		return
    	}
    	b := r.throttle.Burst()  // maximum available tokens
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 14:57:31 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. compat/maven-settings/src/main/java/org/apache/maven/settings/io/xpp3/SettingsXpp3Reader.java

         * any.
         * @return Model
         */
        public Settings read(Reader reader) throws IOException, XmlPullParserException {
            try {
                return new Settings(delegate.read(reader));
            } catch (XMLStreamException e) {
                throw new XmlPullParserException(e.getMessage(), null, e);
            }
        }
    
        /**
         * Method read.
         *
         * @param in a in object.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  10. src/main/java/jcifs/SmbRandomAccess.java

        void close () throws SmbException;
    
    
        /**
         * Read a single byte from the current position
         * 
         * @return read byte, -1 if EOF
         * @throws SmbException
         */
        int read () throws SmbException;
    
    
        /**
         * Read into buffer from current position
         * 
         * @param b
         *            buffer
         * @return number of bytes read
         * @throws SmbException
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.5K bytes
    - Viewed (0)
Back to top