Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 230 for socketio (0.18 sec)

  1. mockwebserver/src/test/java/mockwebserver3/RecordedRequestTest.kt

    import java.net.InetAddress
    import java.net.Socket
    import okhttp3.Headers
    import okhttp3.Headers.Companion.headersOf
    import okhttp3.internal.EMPTY_HEADERS
    import okio.Buffer
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    
    @Timeout(30)
    class RecordedRequestTest {
      private val headers: Headers = EMPTY_HEADERS
    
      @Test fun testIPv4() {
        val socket =
          FakeSocket(
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.1K bytes
    - Viewed (0)
  2. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/RecordedRequest.kt

        sequenceNumber: Int,
        socket: Socket,
        failure: IOException? = null,
      ) {
        this.requestLine = requestLine
        this.headers = headers
        this.chunkSizes = chunkSizes
        this.bodySize = bodySize
        this.body = body
        this.sequenceNumber = sequenceNumber
        this.failure = failure
    
        if (socket is SSLSocket) {
          try {
            this.handshake = socket.session.handshake()
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 4.1K bytes
    - Viewed (2)
  3. okhttp/src/test/java/okhttp3/ChannelSocketFactory.kt

     */
    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 {
        return SocketChannel.open().socket()
      }
    
      override fun createSocket(
        host: String,
        port: Int,
      ): Socket = TODO("Not yet implemented")
    
      override fun createSocket(
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.4K bytes
    - Viewed (0)
  4. mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt

       */
      val handshakeServerNames: List<String>
    
      init {
        if (socket is SSLSocket) {
          try {
            this.handshake = socket.session.handshake()
            this.handshakeServerNames = Platform.get().getHandshakeServerNames(socket)
          } catch (e: IOException) {
            throw IllegalArgumentException(e)
          }
        } else {
          this.handshake = null
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Tue Jan 23 14:31:42 GMT 2024
    - 3.8K bytes
    - Viewed (1)
  5. okhttp/src/main/kotlin/okhttp3/internal/platform/AndroidPlatform.kt

        ).filter { it.isSupported() }
    
      @Throws(IOException::class)
      override fun connectSocket(
        socket: Socket,
        address: InetSocketAddress,
        connectTimeout: Int,
      ) {
        try {
          socket.connect(address, connectTimeout)
        } catch (e: ClassCastException) {
          // On android 8.0, socket.connect throws a ClassCastException due to a bug
          // see https://issuetracker.google.com/issues/63649622
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

      val connectionPool: RealConnectionPool,
      override val route: Route,
      /** The low-level TCP socket. */
      private var rawSocket: Socket?,
      /**
       * The application layer socket. Either an [SSLSocket] layered over [rawSocket], or [rawSocket]
       * itself if this connection does not use SSL.
       */
      private var socket: Socket?,
      private var handshake: Handshake?,
      private var protocol: Protocol?,
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/ConnectionSpec.kt

      }
    
      /**
       * Returns `true` if the socket, as currently configured, supports this connection spec. In
       * order for a socket to be compatible the enabled cipher suites and protocols must intersect.
       *
       * For cipher suites, at least one of the [required cipher suites][cipherSuites] must match the
       * socket's enabled cipher suites. If there are no required cipher suites the socket must have at
       * least one cipher suite enabled.
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 13.4K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

            .socketFactory(
              object : DelegatingSocketFactory(getDefault()) {
                override fun configureSocket(socket: Socket): Socket {
                  socket.receiveBufferSize = socketBufferSize
                  socket.sendBufferSize = socketBufferSize
                  return socket
                }
              },
            )
            .writeTimeout(Duration.ofMillis(500))
            .build()
        server.start()
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 131.7K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

      // These properties are initialized by connect() and never reassigned.
    
      /** The low-level TCP socket. */
      private var rawSocket: Socket? = null
    
      /**
       * The application layer socket. Either an [SSLSocket] layered over [rawSocket], or [rawSocket]
       * itself if this connection does not use SSL.
       */
      internal var socket: Socket? = null
      private var handshake: Handshake? = null
      private var protocol: Protocol? = null
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 18.6K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/compare/testdata/configdump.json

                  },
                  "service_name": "inbound-vip|9080|http|ratings.default.svc.cluster.local"
                },
                "transport_socket": {
                  "name": "internal_upstream",
                  "typed_config": {
                    "@type": "type.googleapis.com/envoy.extensions.transport_sockets.internal_upstream.v3.InternalUpstreamTransport",
                    "passthrough_metadata": [
                      {
                        "kind": {
    Json
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Mar 12 10:02:09 GMT 2024
    - 52K bytes
    - Viewed (0)
Back to top