Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for ConnectionListener (0.09 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectionListener.kt

        call: Call,
      ) {}
    
      /**
       * Invoked when a connection is marked for no new exchanges.
       */
      open fun noNewExchanges(connection: Connection) {}
    
      companion object {
        val NONE: ConnectionListener = object : ConnectionListener() {}
      }
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/ConnectionPool.kt

        taskRunner: TaskRunner = TaskRunner.INSTANCE,
        connectionListener: ConnectionListener = ConnectionListener.NONE,
      ) : this(
        RealConnectionPool(
          taskRunner = taskRunner,
          maxIdleConnections = maxIdleConnections,
          keepAliveDuration = keepAliveDuration,
          timeUnit = timeUnit,
          connectionListener = connectionListener,
        ),
      )
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:55:03 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/internal.kt

    internal fun OkHttpClient.Builder.taskRunnerInternal(taskRunner: TaskRunner) = this.taskRunner(taskRunner)
    
    internal fun buildConnectionPool(
      connectionListener: ConnectionListener,
      taskRunner: TaskRunner,
    ): ConnectionPool =
      ConnectionPool(
        connectionListener = connectionListener,
        taskRunner = taskRunner,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

        RealConnectionPool(
          taskRunner = taskRunner,
          maxIdleConnections = maxIdleConnections,
          keepAliveDuration = 100L,
          timeUnit = TimeUnit.NANOSECONDS,
          connectionListener = ConnectionListener.NONE,
        )
    
      /** Returns an address that's without an SSL socket factory or hostname verifier.  */
      fun newAddress(
        uriHost: String = this.uriHost,
        uriPort: Int = this.uriPort,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Oct 08 03:50:05 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

    import java.util.Deque
    import java.util.concurrent.ConcurrentLinkedDeque
    import java.util.concurrent.TimeUnit
    import okhttp3.ConnectionEvent.NoNewExchanges
    import okhttp3.internal.connection.ConnectionListener
    import okhttp3.internal.connection.RealConnection
    import okio.IOException
    import org.junit.jupiter.api.Assertions
    
    internal open class RecordingConnectionListener(
      /**
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  6. okhttp-testing-support/src/main/kotlin/okhttp3/ConnectionEvent.kt

      "INVISIBLE_MEMBER",
      "INVISIBLE_REFERENCE",
    )
    
    package okhttp3
    
    import java.io.IOException
    import okhttp3.internal.SuppressSignatureCheck
    
    /** Data classes that correspond to each of the methods of [ConnectionListener]. */
    @SuppressSignatureCheck
    sealed class ConnectionEvent {
      abstract val timestampNs: Long
      open val connection: Connection?
        get() = null
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt

      open val fastFallback: Boolean get() = true
    
      private var client: OkHttpClient =
        clientTestRule
          .newClientBuilder()
          .connectionPool(ConnectionPool(connectionListener = listener))
          .fastFallback(fastFallback)
          .build()
    
      @BeforeEach
      fun setUp() {
        platform.assumeNotOpenJSSE()
        platform.assumeNotBouncyCastle()
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 18:33:48 UTC 2025
    - 9.7K bytes
    - Viewed (0)
Back to top