- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 140 for Sall (0.12 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectionUser.kt
import java.net.Socket import okhttp3.Connection import okhttp3.Handshake import okhttp3.HttpUrl import okhttp3.Protocol import okhttp3.Route /** * The object that is asking for a connection. Either a call or a connect policy from the pool. */ interface ConnectionUser { fun addPlanToCancel(connectPlan: ConnectPlan) fun removePlanToCancel(connectPlan: ConnectPlan) fun updateRouteDatabaseAfterSuccess(route: Route)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 2.2K bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/OAuthSessionFactory.java
import okhttp3.mockwebserver.RecordedRequest; import okio.ByteString; /** * Runs a MockWebServer on localhost and uses it as the backend to receive an OAuth session. * * <p>Clients should call {@link #start}, {@link #newAuthorizeUrl} and {@link #close} in that order. * Clients may request multiple sessions. */ public final class OAuthSessionFactory extends Dispatcher implements Closeable {
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Aug 12 07:26:27 GMT 2021 - 3.8K bytes - Viewed (0) -
gradlew
# command line, like: # # ksh Gradle # # Busybox and similar reduced shells will NOT work, because this script # requires all of these POSIX shell features: # * functions; # * expansions «$var», «${var}», «${var:-default}», «${var+SET}», # «${var#prefix}», «${var%suffix}», and «$( cmd )»;
Shell Script - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Dec 24 09:00:26 GMT 2023 - 8.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSession.kt
import javax.net.ssl.SSLPeerUnverifiedException import javax.net.ssl.SSLSession import javax.net.ssl.SSLSessionContext import javax.security.cert.X509Certificate /** An [SSLSession] that delegates all calls. */ abstract class DelegatingSSLSession(protected val delegate: SSLSession?) : SSLSession { override fun getId(): ByteArray { return delegate!!.id } override fun getSessionContext(): SSLSessionContext {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst() as FakePlan if (nextPlanIndex >= plans.size && autoGeneratePlans) addPlan() require(nextPlanIndex < plans.size) { "not enough plans! call addPlan() or set autoGeneratePlans=true in the test to set this up" } val result = plans[nextPlanIndex++] events += "take plan ${result.id}" if (result.yieldBeforePlanReturns) { taskFaker.yield()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseJvmTest.kt
assertThat(response.trailers()).isEmpty() } @Test fun testFailsIfTrailersNotSet() { val response = newResponse("".toResponseBody()) { // All live paths (Http1, Http2) in OkHttp do this trailers { error("trailers not available") } } assertFailsWith<IllegalStateException>(message = "trailers not available") { response.trailers() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt
import java.util.function.BiFunction import javax.net.ssl.HandshakeCompletedListener import javax.net.ssl.SSLParameters import javax.net.ssl.SSLSession import javax.net.ssl.SSLSocket /** An [SSLSocket] that delegates all calls. */ abstract class DelegatingSSLSocket(protected val delegate: SSLSocket?) : SSLSocket() { @Throws(IOException::class) override fun shutdownInput() { delegate!!.shutdownInput() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.9K 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 May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt
runTest { val call = ClosableCall() supervisorScope { assertFailsWith<CancellationException> { coroutineScope { call.afterCallbackOnResponse = { coroutineContext.job.cancel() } call.executeAsync() } } } assertThat(call.canceled).isTrue()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 5.4K 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 May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0)