Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for connectionAcquired (0.11 sec)

  1. okhttp/src/test/java/okhttp3/EventListenerTest.kt

          )
        val response = call.execute()
        assertThat(response.code).isEqualTo(200)
        response.body.close()
        val connectionAcquired = listener.removeUpToEvent<ConnectionAcquired>()
        assertThat(connectionAcquired.call).isSameAs(call)
        assertThat(connectionAcquired.connection).isNotNull()
      }
    
      @Test
      fun noConnectionFoundOnFollowUp() {
        server.enqueue(
          MockResponse.Builder()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/RouteFailureTest.kt

    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue May 14 17:48:07 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt

          .execute().close()
    
        assertThat(listener.recordedEventTypes()).containsExactly(
          "ConnectStart",
          "ConnectEnd",
          "ConnectionAcquired",
          "ConnectionReleased",
          "ConnectionAcquired",
          "ConnectionReleased",
        )
      }
    
      @Test
      @Throws(IOException::class)
      fun successfulEmptyH2CallEventSequence() {
        enableTls()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt

       * Invoked when a connection is released as no longer required.
       */
      open fun connectionClosed(connection: Connection) {}
    
      /**
       * Invoked when a call is assigned a particular connection.
       */
      open fun connectionAcquired(
        connection: Connection,
        call: Call,
      ) {}
    
      /**
       * Invoked when a call no longer uses a connection.
       */
      open fun connectionReleased(
        connection: Connection,
        call: Call,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  5. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt

        proxy: Proxy,
        protocol: Protocol?,
        ioe: IOException,
      ) {
        logWithTime("connectFailed: $protocol $ioe")
      }
    
      override fun connectionAcquired(
        call: Call,
        connection: Connection,
      ) {
        logWithTime("connectionAcquired: $connection")
      }
    
      override fun connectionReleased(
        call: Call,
        connection: Connection,
      ) {
        logWithTime("connectionReleased")
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 11:07:32 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

            }
            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 ||
          it is ConnectionReleased ||
          it is Canceled ||
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/EventListener.kt

       * to the [Call.request] is a redirect to a different address.
       */
      open fun connectionAcquired(
        call: Call,
        connection: Connection,
      ) {
      }
    
      /**
       * Invoked after a connection has been released for the `call`.
       *
       * This method is always invoked after [connectionAcquired].
       *
       * This can be invoked more than 1 time for a single [Call]. For example, if the response to the
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt

      override fun connectionConnectEnd(
        connection: Connection,
        route: Route,
      ) {
        poolConnectionListener.connectEnd(connection, route, call)
      }
    
      override fun connectionAcquired(connection: Connection) {
        eventListener.connectionAcquired(call, connection)
      }
    
      override fun acquireConnectionNoEvents(connection: RealConnection) {
        call.acquireConnectionNoEvents(connection)
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Mar 06 17:33:38 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  9. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

          client =
            OkHttpClient.Builder()
              .eventListenerFactory(
                clientTestRule.wrap(
                  object : EventListener() {
                    override fun connectionAcquired(
                      call: Call,
                      connection: Connection,
                    ) {
                      socketClass = connection.socket().javaClass.name
                    }
                  },
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 27K bytes
    - Viewed (0)
  10. okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt

          .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\}""",
            ),
          )
          .assertLogMatch(Regex("""requestHeadersStart"""))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top