- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for ConnectionListener (0.3 sec)
-
okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt
/** * Invoked when a connection is marked for no new exchanges. */ open fun noNewExchanges(connection: Connection) {} @ExperimentalOkHttpApi companion object { val NONE: ConnectionListener = object : ConnectionListener() {} }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 2.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
keepAliveDuration: Long = 5, timeUnit: TimeUnit = TimeUnit.MINUTES, connectionListener: ConnectionListener = ConnectionListener.NONE, ) : this( taskRunner = TaskRunner.INSTANCE, maxIdleConnections = maxIdleConnections, keepAliveDuration = keepAliveDuration, timeUnit = timeUnit, connectionListener = connectionListener, ) // Public API constructor( maxIdleConnections: Int,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
private var handshake: Handshake?, private var protocol: Protocol?, private var source: BufferedSource?, private var sink: BufferedSink?, private val pingIntervalMillis: Int, internal val connectionListener: ConnectionListener, ) : Http2Connection.Listener(), Connection, ExchangeCodec.Carrier { private var http2Connection: Http2Connection? = null internal val lock: ReentrantLock = ReentrantLock()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt
connection.connectionListener.connectionAcquired(connection, call) } override fun connectionConnectionReleased(connection: RealConnection) { connection.connectionListener.connectionReleased(connection, call) } override fun connectionConnectionClosed(connection: RealConnection) { connection.connectionListener.connectionClosed(connection) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 3.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/http2/Http2FlowControlConnectionListener.kt
* limitations under the License. */ package okhttp3.internal.http2 import okhttp3.ConnectionListener import okhttp3.internal.http2.flowcontrol.WindowCounter /** * ConnectionListener that outputs CSV for flow control of client receiving streams. */ class Http2FlowControlConnectionListener : ConnectionListener(), FlowControlListener { val start = System.currentTimeMillis()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
} if (this.connection == null) { toClose?.closeQuietly() eventListener.connectionReleased(this, connection) connection.connectionListener.connectionReleased(connection, this) if (toClose != null) { connection.connectionListener.connectionClosed(connection) } } else { check(toClose == null) // If we still have a connection we shouldn't be closing any sockets.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
buildConnectionPool( connectionListener = connectionListener, taskRunner = taskRunner, ), ) .dispatcher(Dispatcher(backend.executor)) .taskRunnerInternal(taskRunner) } else { OkHttpClient.Builder() .connectionPool(ConnectionPool(connectionListener = connectionListener)) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
return RealConnectionPool( taskRunner = taskRunner, maxIdleConnections = maxIdleConnections, keepAliveDuration = 100L, timeUnit = TimeUnit.NANOSECONDS, connectionListener = ConnectionListener.NONE, exchangeFinderFactory = { pool, address, user -> FastFallbackExchangeFinder( routePlanner ?: RealRoutePlanner( taskRunner = taskRunner,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
/** * An override to ignore the normal order that is enforced. * EventListeners added by Interceptors will not see all events. */ private val enforceOrder: Boolean = true, ) : ConnectionListener() { val eventSequence: Deque<ConnectionEvent> = ConcurrentLinkedDeque() private val forbiddenLocks = mutableSetOf<Any>() /** The timestamp of the last taken event, used to measure elapsed time between events. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
toClose.closeQuietly() connectionListener.connectionClosed(connection) } else if (noNewExchangesEvent) { connectionListener.noNewExchanges(connection) } } return null } fun put(connection: RealConnection) { connection.lock.assertHeld() connections.add(connection) // connection.queueEvent { connectionListener.connectEnd(connection) } scheduleCloser()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0)