Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for ConnectEnd (0.06 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/RouteFailureTest.kt

    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt

        response.body.close()
        assertThat(listener.recordedEventTypes()).containsExactly(
          "ConnectStart",
          "ConnectEnd",
          "ConnectionAcquired",
          "ConnectionReleased",
        )
        val event = listener.removeUpToEvent(ConnectionEvent.ConnectEnd::class.java)
        assertThat(event.connection.route().proxy).isEqualTo(proxy)
      }
    
      private fun enableTls() {
        client =
          client
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt

              addAll(listOf("ConnectStart", "ConnectEnd"))
            }
            addAll(listOf("ConnectionAcquired", "ConnectionReleased", "CallEnd"))
          }
    
        assertThat(events2).isEqualTo(expectedEvents2)
      }
    
      private fun isConnectionEvent(it: CallEvent?) =
        it is CallStart ||
          it is CallEnd ||
          it is ConnectStart ||
          it is ConnectEnd ||
          it is ConnectionAcquired ||
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  4. okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt

          .assertLogMatch(Regex("""dnsStart: ${url.host}"""))
          .assertLogMatch(Regex("""dnsEnd: \[.+]"""))
          .assertLogMatch(Regex("""connectStart: ${url.host}/.+ DIRECT"""))
          .assertLogMatch(Regex("""connectEnd: http/1.1"""))
          .assertLogMatch(
            Regex(
              """connectionAcquired: Connection\{${url.host}:\d+, proxy=DIRECT hostAddress=${url.host}/.+ cipherSuite=none protocol=http/1\.1\}""",
            ),
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

     *
     *  * call ([callStart], [callEnd], [callFailed])
     *    * proxy selection ([proxySelectStart], [proxySelectEnd])
     *    * dns ([dnsStart], [dnsEnd])
     *    * connect ([connectStart], [connectEnd], [connectFailed])
     *      * secure connect ([secureConnectStart], [secureConnectEnd])
     *    * connection held ([connectionAcquired], [connectionReleased])
     *      * request ([requestFailed])
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt

        assertThat(listener.recordedEventTypes().filter { it == "ConnectFailed" }).hasSize(1)
        assertThat(listener.recordedEventTypes().filter { it == "ConnectEnd" }).hasSize(1)
      }
    
      @Test
      fun reachesIpv6WhenIpv4IsDown() {
        serverIpv4.close()
        serverIpv6.enqueue(
          MockResponse(body = "hello from IPv6"),
        )
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 24.8K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/tls/ClientAuthTest.kt

          call.execute()
        }
    
        // Observed Events are variable
        // JDK 14
        // CallStart, ProxySelectStart, ProxySelectEnd, DnsStart, DnsEnd, ConnectStart, SecureConnectStart,
        // SecureConnectEnd, ConnectEnd, ConnectionAcquired, RequestHeadersStart, RequestHeadersEnd,
        // ResponseFailed, ConnectionReleased, CallFailed
        // JDK 8
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

          }
        }
        return null
      }
    
      fun put(connection: RealConnection) {
        connection.assertLockHeld()
    
        connections.add(connection)
    //    connection.queueEvent { connectionListener.connectEnd(connection) }
        scheduleCloser()
      }
    
      /**
       * Notify this pool that [connection] has become idle. Returns true if the connection has been
       * removed from the pool and should be closed.
       */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt

            override fun secureConnectStart(call: Call) = TODO()
    
            override fun secureConnectEnd(
              call: Call,
              handshake: Handshake?,
            ) = TODO()
    
            override fun connectEnd(
              call: Call,
              inetSocketAddress: InetSocketAddress,
              proxy: Proxy,
              protocol: Protocol?,
            ) = TODO()
    
            override fun connectFailed(
              call: Call,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 46.5K bytes
    - Viewed (0)
Back to top