Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 1,555 for readN (0.03 sec)

  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.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/SmbFileInputStream.java

    /**
     * Reads up to b.length bytes of data from this input stream into an array of bytes.
     *
     * @throws IOException if a network error occurs
     */
    
        public int read( byte[] b ) throws IOException {
            return read( b, 0, b.length );
        }
    
    /**
     * Reads up to len bytes of data from this input stream into an array of bytes.
     *
     * @throws IOException if a network error occurs
     */
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 7.9K bytes
    - Viewed (0)
  3. impl/maven-core/src/main/java/org/apache/maven/artifact/repository/metadata/io/MetadataReader.java

         * @throws IOException If the metadata could not be deserialized.
         * @throws MetadataParseException If the input format could not be parsed.
         */
        Metadata read(File input, Map<String, ?> options) throws IOException, MetadataParseException;
    
        /**
         * Reads the metadata from the specified character reader. The reader will be automatically closed before the method
         * returns.
         *
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  4. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/SettingsReader.java

         * @throws IOException If the settings could not be deserialized.
         * @throws SettingsParseException If the input format could not be parsed.
         */
        Settings read(File input, Map<String, ?> options) throws IOException, SettingsParseException;
    
        /**
         * Reads the settings from the specified character reader. The reader will be automatically closed before the method
         * returns.
         *
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  5. compat/maven-toolchain-builder/src/main/java/org/apache/maven/toolchain/io/ToolchainsReader.java

         * @throws ToolchainsParseException If the input format could not be parsed.
         */
        PersistedToolchains read(File input, Map<String, ?> options) throws IOException, ToolchainsParseException;
    
        /**
         * Reads the toolchains from the specified character reader. The reader will be automatically closed before the
         * method returns.
         *
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.5K bytes
    - Viewed (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
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  7. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 28 20:13:02 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  8. 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 (0 > b1) {
          throw new EOFException();
        }
    
        return b1;
      }
    
      /**
       * Reads an unsigned {@code short} as specified by {@link DataInputStream#readUnsignedShort()},
       * except using little-endian byte order.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

        @Throws(IOException::class)
        override fun read(
          sink: Buffer,
          byteCount: Long,
        ): Long {
          while (left == 0) {
            source.skip(padding.toLong())
            padding = 0
            if (flags and FLAG_END_HEADERS != 0) return -1L
            readContinuationHeader()
            // TODO: test case for empty continuation header?
          }
    
          val read = source.read(sink, minOf(byteCount, left.toLong()))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  10. 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)
Back to top