Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for Channels (0.08 sec)

  1. 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)
  2. 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)
  3. samples/slack/src/main/java/okhttp3/slack/RtmStartResponse.java

    import okhttp3.HttpUrl;
    
    /** See https://api.slack.com/methods/rtm.start. */
    public final class RtmStartResponse {
      HttpUrl url;
      Object self;
      Object team;
      List<Object> users;
      List<Object> channels;
      List<Object> groups;
      List<Object> mpims;
      List<Object> ims;
      List<Object> bots;
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Oct 23 15:24:22 UTC 2016
    - 943 bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/io/PackageSanityTests.java

     */
    
    package com.google.common.io;
    
    import static java.nio.charset.StandardCharsets.UTF_8;
    
    import com.google.common.testing.AbstractPackageSanityTests;
    import java.lang.reflect.Method;
    import java.nio.channels.FileChannel.MapMode;
    import java.nio.charset.CharsetEncoder;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Basic sanity tests for the entire package.
     *
     * @author Ben Yu
     */
    
    @NullUnmarked
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/ChannelSocketFactory.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3
    
    import java.net.InetAddress
    import java.net.Socket
    import java.nio.channels.SocketChannel
    import javax.net.SocketFactory
    
    class ChannelSocketFactory : SocketFactory() {
      override fun createSocket(): Socket = SocketChannel.open().socket()
    
      override fun createSocket(
        host: String,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  6. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java

          return endpoint;
        }
    
        @Override public Socket accept() throws IOException {
          try {
            UnixSocketChannel channel = serverSocketChannel.accept();
            return new TunnelingUnixSocket(path, channel, endpoint);
          } catch (ClosedChannelException e) {
            SocketException exception = new SocketException();
            exception.initCause(e);
            throw exception;
          }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Feb 12 16:33:52 UTC 2019
    - 3.1K bytes
    - Viewed (0)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt

     */
    package okhttp3
    
    import java.io.IOException
    import java.io.InputStream
    import java.io.OutputStream
    import java.net.InetAddress
    import java.net.SocketAddress
    import java.net.SocketException
    import java.nio.channels.SocketChannel
    import java.util.function.BiFunction
    import javax.net.ssl.HandshakeCompletedListener
    import javax.net.ssl.SSLParameters
    import javax.net.ssl.SSLSession
    import javax.net.ssl.SSLSocket
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java

      private final File path;
      private InetSocketAddress inetSocketAddress;
    
      TunnelingUnixSocket(File path, UnixSocketChannel channel) {
        super(channel);
        this.path = path;
      }
    
      TunnelingUnixSocket(File path, UnixSocketChannel channel, InetSocketAddress address) {
        this(path, channel);
        this.inetSocketAddress = address;
      }
    
      @Override public void connect(SocketAddress endpoint) throws IOException {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Feb 12 16:33:52 UTC 2019
    - 1.9K bytes
    - Viewed (0)
Back to top