Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 1,340 for readN (0.09 seconds)

  1. internal/ringbuffer/README.md

    Regular Reads will block until data is available, but not wait for a full buffer. 
    Writes will block until there is space available and writes bigger than the buffer will wait for reads to make space.
    
    `TryRead` and `TryWrite` are still available for non-blocking reads and writes.
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 15 00:11:04 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/io/MultiReaderTest.java

        Reader joinedReader = CharSource.concat(list).openStream();
    
        assertTrue(joinedReader.ready());
        assertEquals('a', joinedReader.read());
        assertEquals('a', joinedReader.read());
        assertEquals(-1, joinedReader.read());
        assertFalse(joinedReader.ready());
      }
    
      public void testSimple() throws Exception {
        String testString = "abcdefgh";
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  3. android/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
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.7K bytes
    - Click Count (0)
  4. 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
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.3K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/io/MultiReader.java

          current = it.next().openStream();
        }
      }
    
      @Override
      public int read(char[] cbuf, int off, int len) throws IOException {
        checkNotNull(cbuf);
        if (current == null) {
          return -1;
        }
        int result = current.read(cbuf, off, len);
        if (result == -1) {
          advance();
          return read(cbuf, off, len);
        }
        return result;
      }
    
      @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:37:28 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  6. docs/contribute/concurrency.md

    Framing rules make it impractical to implement http/2 correctly on a single blocking thread. The flow-control features introduce feedback between reads and writes, requiring writes to acknowledge reads and reads to throttle writes.
    
    In OkHttp we expose a blocking API over a framed protocol. This document explains the code and policy that makes that work.
    
    ### Threads
    
    #### Application's calling thread
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 06 16:35:36 GMT 2022
    - 7K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/io/LittleEndianDataInputStream.java

        return (int) in.skip(n);
      }
    
      @CanIgnoreReturnValue // to skip a byte
      @Override
      public int readUnsignedByte() throws IOException {
        int b1 = in.read();
        if (b1 < 0) {
          throw new EOFException();
        }
    
        return b1;
      }
    
      /**
       * Reads an unsigned {@code short} as specified by {@link DataInputStream#readUnsignedShort()},
       * except using little-endian byte order.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Feb 12 03:49:18 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  8. compat/maven-model-builder/src/main/java/org/apache/maven/model/io/ModelReader.java

         * @throws IOException If the model could not be deserialized.
         * @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.
         *
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  9. src/bufio/bufio_test.go

    	buf := make([]byte, 1)
    	if _, err := b.Read(nil); err != nil {
    		t.Fatalf("1st nil Read = %v; want nil", err)
    	}
    	if _, err := b.Read(buf); err != errFake {
    		t.Fatalf("1st Read = %v; want errFake", err)
    	}
    	if _, err := b.Read(nil); err != nil {
    		t.Fatalf("2nd nil Read = %v; want nil", err)
    	}
    	if _, err := b.Read(buf); err != nil {
    		t.Fatalf("3rd Read with buffer = %v; want nil", err)
    	}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Feb 07 01:08:54 GMT 2025
    - 51.6K bytes
    - Click Count (0)
  10. 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],
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Oct 07 19:46:36 GMT 2025
    - 26.9K bytes
    - Click Count (0)
Back to Top