- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 53 for carl (0.5 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
// the call, but they may be accessed by other threads for duplex requests. /** True if this call still has a request body open. */ private var requestBodyOpen = false /** True if this call still has a response body open. */ private var responseBodyOpen = false /** True if there are more exchanges expected for this call. */ private var expectMoreExchanges = true
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-coroutines/src/main/kotlin/okhttp3/JvmCallExtensions.kt
import okio.IOException @ExperimentalCoroutinesApi // resume with a resource cleanup. suspend fun Call.executeAsync(): Response = suspendCancellableCoroutine { continuation -> continuation.invokeOnCancellation { this.cancel() } this.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { continuation.resumeWithException(e) }
Plain Text - Registered: Fri Apr 12 11:42:09 GMT 2024 - Last Modified: Fri Apr 05 11:25:23 GMT 2024 - 1.4K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSources.kt
*/ package okhttp3.sse import okhttp3.Call import okhttp3.OkHttpClient import okhttp3.Response import okhttp3.sse.internal.RealEventSource object EventSources { @Deprecated( message = "required for binary-compatibility!", level = DeprecationLevel.HIDDEN, ) @JvmStatic fun createFactory(client: OkHttpClient) = createFactory(client as Call.Factory) @JvmStatic
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:18:15 GMT 2024 - 1.6K bytes - Viewed (1) -
docs/changelogs/changelog_4x.md
## Version 4.0.1 _2019-07-10_ * Fix: Tolerate null-hostile lists in public API. Lists created with `List.of(...)` don't like it when you call `contains(null)` on them! * Fix: Retain binary-compatibility in `okhttp3.internal.HttpHeaders.hasBody()`. Some unscrupulous coders call this and we don't want their users to suffer. ## Version 4.0.0 _2019-06-26_
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
noNewExchangesEvent = !noNewExchanges noNewExchanges = true // If this route hasn't completed a call, avoid it for new connections. if (successCount == 0) { if (e != null) { connectFailed(call.client, route, e) } routeFailureCount++ } } Unit } if (noNewExchangesEvent) {
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-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
address = address, proxy = proxy, socketAddress = socketAddress, ) } fun newChain(call: RealCall): RealInterceptorChain { return RealInterceptorChain( call = call, interceptors = listOf(), index = 0, exchange = null, request = call.request(), connectTimeoutMillis = 10_000, readTimeoutMillis = 10_000, writeTimeoutMillis = 10_000, )
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/src/test/java/okhttp3/CallTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt
} this.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { continuation.resumeWithException(e) } override fun onResponse( call: Call, response: Response, ) { continuation.resume(response) { response.closeQuietly() } } }, )
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/RouteSelectorTest.kt
fastFallback: Boolean = false, call: RealCall = this.call, ): RouteSelector { return RouteSelector( address = address, routeDatabase = routeDatabase, fastFallback = fastFallback, connectionUser = CallConnectionUser(call, ConnectionListener.NONE, newChain(call)), ) } private fun newChain(call: RealCall): RealInterceptorChain { return RealInterceptorChain(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 20.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FailingCall.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import okio.Timeout open class FailingCall : Call { override fun request(): Request = error("unexpected") override fun execute(): Response = error("unexpected") override fun enqueue(responseCallback: Callback): Unit = error("unexpected")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 1.1K bytes - Viewed (0)