Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for getChannel (0.08 sec)

  1. okhttp/src/test/java/okhttp3/internal/cache2/FileOperatorTest.kt

          FileOperator(
            randomAccessFile!!.getChannel(),
          )
        val buffer = Buffer()
        operator.read(0, buffer, 5)
        assertThat(buffer.readUtf8()).isEqualTo("Hello")
        operator.read(4, buffer, 5)
        assertThat(buffer.readUtf8()).isEqualTo("o, Wo")
      }
    
      @Test
      fun write() {
        val operator =
          FileOperator(
            randomAccessFile!!.getChannel(),
          )
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/core/io/FileUtil.java

        public static byte[] readBytes(final File file) {
            assertArgumentNotNull("file", file);
    
            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 {
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 9K bytes
    - Viewed (0)
  3. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java

                FileChannel channel = null;
                FileLock lock = null;
                try {
                    Properties props = new Properties();
    
                    channel = new RandomAccessFile(touchfile, "rw").getChannel();
                    lock = channel.lock();
    
                    if (touchfile.canRead()) {
                        getLogger().debug("Reading resolution-state from: " + touchfile);
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  4. .teamcity/.mvn/wrapper/MavenWrapperDownloader.java

            }
            URL website = new URL(urlString);
            ReadableByteChannel rbc;
            rbc = Channels.newChannel(website.openStream());
            FileOutputStream fos = new FileOutputStream(destination);
            fos.getChannel().transferFrom(rbc, 0, Long.MAX_VALUE);
            fos.close();
            rbc.close();
        }
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Feb 26 01:48:39 UTC 2020
    - 4.8K bytes
    - Viewed (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt

        return delegate!!.trafficClass
      }
    
      @Throws(IOException::class)
      override fun sendUrgentData(value: Int) {
        delegate!!.sendUrgentData(value)
      }
    
      override fun getChannel(): SocketChannel {
        return delegate!!.channel
      }
    
      override fun getHandshakeSession(): SSLSession {
        return delegate!!.handshakeSession
      }
    
      override fun getApplicationProtocol(): String {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/core/io/CopyUtil.java

         *            ファイル出力ストリーム
         * @return コピーしたバイト数
         */
        protected static int copyInternal(final FileInputStream in, final FileOutputStream out) {
            final FileChannel ic = in.getChannel();
            final FileChannel oc = out.getChannel();
            return (int) ChannelUtil.transfer(ic, oc);
        }
    
        /**
         * リーダーの内容をライターにコピーします。
         * <p>
         * リーダー、ライターともクローズされません。
         * </p>
         *
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 52.4K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/io/Files.java

        @Override
        public byte[] read() throws IOException {
          Closer closer = Closer.create();
          try {
            FileInputStream in = closer.register(openStream());
            return ByteStreams.toByteArray(in, in.getChannel().size());
          } catch (Throwable e) {
            throw closer.rethrow(e);
          } finally {
            closer.close();
          }
        }
    
        @Override
        public String toString() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jul 22 19:03:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  8. guava/src/com/google/common/io/Files.java

        @Override
        public byte[] read() throws IOException {
          Closer closer = Closer.create();
          try {
            FileInputStream in = closer.register(openStream());
            return ByteStreams.toByteArray(in, in.getChannel().size());
          } catch (Throwable e) {
            throw closer.rethrow(e);
          } finally {
            closer.close();
          }
        }
    
        @Override
        public String toString() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jul 22 19:03:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  9. okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat

    tashkent.su
    termez.su
    togliatti.su
    troitsk.su
    tselinograd.su
    tula.su
    tuva.su
    vladikavkaz.su
    vladimir.su
    vologda.su
    
    // Fancy Bits, LLC : http://getchannels.com
    // Submitted by Aman Gupta <aman@getchannels.com>
    channelsdvr.net
    u.channelsdvr.net
    
    // Fastly Inc. : http://www.fastly.com/
    // Submitted by Fastly Security <******@****.***>
    edgecompute.app
    fastly-edge.com
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 240.3K bytes
    - Viewed (0)
Back to top