- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 236 for Sall (0.16 sec)
-
okhttp/src/main/kotlin/okhttp3/EventListener.kt
* * This can be invoked more than 1 time for a single [Call]. For example, if the response * 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`. *
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
routes: List<Route>?, requireMultiplexed: Boolean, ): RealConnection? { for (connection in connections) { // In the first synchronized block, acquire the connection if it can satisfy this call. val acquired = synchronized(connection) { when { requireMultiplexed && !connection.isMultiplexed -> false !connection.isEligible(address, routes) -> false
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 9.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
* * Every [edit] call must be matched by a call to [Editor.commit] or [Editor.abort]. Committing is * atomic: a read observes the full set of values as they were before or after the commit, but never * a mix of values. * * Clients call [get] to read a snapshot of an entry. The read will observe the value at the time * that [get] was called. Updates and removals after the call do not impact ongoing reads. *
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
} if (headersQueue.isNotEmpty()) { return headersQueue.removeFirst() } throw errorException ?: StreamResetException(errorCode!!) } /** * Returns the trailers. It is only safe to call this once the source stream has been completely * exhausted. */ @Synchronized @Throws(IOException::class) fun trailers(): Headers {
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheStrategy.kt
* stale). */ class CacheStrategy internal constructor( /** The request to send on the network, or null if this call doesn't use the network. */ val networkRequest: Request?, /** The cached response to return or validate; or null if this call doesn't use a cache. */ val cacheResponse: Response?, ) { class Factory( private val nowMillis: Long, internal val request: Request,
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 12K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/ConnectionEvent.kt
override val timestampNs: Long, val route: Route, val call: Call, ) : ConnectionEvent() data class ConnectFailed( override val timestampNs: Long, val route: Route, val call: Call, val exception: IOException, ) : ConnectionEvent() { override fun closes(event: ConnectionEvent): Boolean = event is ConnectStart && call == event.call && route == event.route } data class ConnectEnd(
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
.url(server.url("/")) .post(AsyncRequestBody()) .build() val call = client.newCall(request) call.timeout().timeout(250, TimeUnit.MILLISECONDS) assertFailsWith<IOException> { call.execute() }.also { expected -> assertThat(expected.message).isEqualTo("timeout") assertTrue(call.isCanceled()) } } @Test fun fullCallTimeoutDoesNotApplyOnceConnected() {
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 23.9K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt
) : EventSource, ServerSentEventReader.Callback, Callback { private var call: Call? = null @Volatile private var canceled = false fun connect(callFactory: Call.Factory) { call = callFactory.newCall(request).apply { enqueue(this@RealEventSource) } } override fun onResponse( call: Call, response: Response, ) { processResponse(response) }
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
docs/features/https.md
By default, OkHttp will attempt a `MODERN_TLS` connection. However by configuring the client connectionSpecs you can allow a fall back to `COMPATIBLE_TLS` connection if the modern configuration fails. ```java OkHttpClient client = new OkHttpClient.Builder() .connectionSpecs(Arrays.asList(ConnectionSpec.MODERN_TLS, ConnectionSpec.COMPATIBLE_TLS))
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Sat Dec 24 00:16:30 GMT 2022 - 10.5K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
} else { null } } override fun secureConnectStart(call: Call) { // Register to capture "Produced ClientHello handshake message". currentThread = Thread.currentThread() logger.addHandler(loggerHandler) } override fun secureConnectEnd( call: Call, handshake: Handshake?, ) { logger.removeHandler(loggerHandler) }
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (1)