Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for Channel (0.04 sec)

  1. src/main/java/org/codelibs/core/nio/ChannelUtil.java

            assertArgumentNotNull("channel", channel);
    
            try {
                return channel.size();
            } catch (final IOException e) {
                throw new IORuntimeException(e);
            }
        }
    
        /**
         * Reads the contents of the file channel into a byte buffer.
         *
         * @param channel
         *            The file channel. Must not be {@literal null}.
         * @param buffer
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt

                listOf(Channel, Standard).flatMap { socketMode ->
                  listOf(DISABLED, STANDARD).map { tlsExtensionMode ->
                    TlsInstance(provider, protocol, tlsVersion, socketMode, tlsExtensionMode)
                  }
                }
              }
            }
          } + Channel + Standard
      }
    }
    
    sealed class SocketMode
    
    object Channel : SocketMode() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 8K bytes
    - Viewed (0)
  3. guava/src/com/google/common/io/ByteStreams.java

          to.write(buf, 0, r);
          total += r;
        }
        return total;
      }
    
      /**
       * Copies all bytes from the readable channel to the writable channel. Does not close or flush
       * either channel.
       *
       * @param from the readable channel to read from
       * @param to the writable channel to write to
       * @return the number of bytes copied
       * @throws IOException if an I/O error occurs
       */
      @J2ktIncompatible
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/core/io/FileUtil.java

            final FileInputStream is = InputStreamUtil.create(file);
            try {
                final FileChannel channel = is.getChannel();
                final ByteBuffer buffer = ByteBuffer.allocate((int) ChannelUtil.size(channel));
                ChannelUtil.read(channel, buffer);
                return buffer.array();
            } finally {
                CloseableUtil.close(is);
            }
        }
    
        /**
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache2/Relay.kt

          }
    
        val fileOperator = FileOperator(file!!.channel)
        fileOperator.write(0, header, FILE_HEADER_SIZE)
      }
    
      @Throws(IOException::class)
      private fun writeMetadata(upstreamSize: Long) {
        val metadataBuffer = Buffer()
        metadataBuffer.write(metadata)
    
        val fileOperator = FileOperator(file!!.channel)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 17:15:47 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache2/FileOperator.kt

    import java.io.IOException
    import java.nio.channels.FileChannel
    import okio.Buffer
    
    /**
     * Read and write a target file. Unlike Okio's built-in `Okio.source(java.io.File file)` and `Okio.sink(java.io.File file)`
     * this class offers:
     *
     *  * **Read/write:** read and write using the same operator.
     *  * **Random access:** access any position within the file.
     *  * **Shared channels:** read and write a file channel that's shared between
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/core/io/CopyUtil.java

            assertArgumentNotNull("out", out);
    
            final FileOutputStream os = OutputStreamUtil.create(out);
            try {
                final FileChannel channel = os.getChannel();
                final ByteBuffer buffer = ByteBuffer.wrap(in);
                return ChannelUtil.write(channel, buffer);
            } finally {
                CloseableUtil.close(os);
            }
        }
    
        /**
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 45.2K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/io/ByteSink.java

     *       typically implemented by opening a stream using one of the methods in the first category,
     *       doing something and finally closing the stream or channel that was opened.
     * </ul>
     *
     * @since 14.0
     * @author Colin Decker
     */
    @J2ktIncompatible
    @GwtIncompatible
    public abstract class ByteSink {
    
      /** Constructor for use by subclasses. */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  9. guava/src/com/google/common/io/ByteSink.java

     *       typically implemented by opening a stream using one of the methods in the first category,
     *       doing something and finally closing the stream or channel that was opened.
     * </ul>
     *
     * @since 14.0
     * @author Colin Decker
     */
    @J2ktIncompatible
    @GwtIncompatible
    public abstract class ByteSink {
    
      /** Constructor for use by subclasses. */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/io/Files.java

        try {
          RandomAccessFile raf =
              closer.register(new RandomAccessFile(file, mode == MapMode.READ_ONLY ? "r" : "rw"));
          FileChannel channel = closer.register(raf.getChannel());
          return channel.map(mode, 0, size == -1 ? channel.size() : size);
        } catch (Throwable e) {
          throw closer.rethrow(e);
        } finally {
          closer.close();
        }
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 32.9K bytes
    - Viewed (0)
Back to top