- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for findall (0.4 sec)
-
okhttp-tls/src/main/kotlin/okhttp3/tls/HeldCertificate.kt
*/ @JvmStatic fun decode(certificateAndPrivateKeyPem: String): HeldCertificate { var certificatePem: String? = null var pkcs8Base64: String? = null for (match in PEM_REGEX.findAll(certificateAndPrivateKeyPem)) { when (val label = match.groups[1]!!.value) { "CERTIFICATE" -> { require(certificatePem == null) { "string includes multiple certificates" }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 21.6K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
check(executed.compareAndSet(false, true)) { "Already Executed" } timeout.enter() callStart() try { client.dispatcher.executed(this) return getResponseWithInterceptorChain() } finally { client.dispatcher.finished(this) } } override fun enqueue(responseCallback: Callback) { check(executed.compareAndSet(false, true)) { "Already Executed" } callStart()
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/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
* * ## Upstream * * In this case the current thread is assigned as the upstream reader. We read bytes from * upstream and copy them to both the file and to the buffer. Finally we release the upstream * reader lock and return the new bytes. * * ## The file * * In this case we copy bytes from the file to the [sink]. * * ## The buffer *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
} } assertEquals(TlsVersion.TLS_1_3, response.handshake?.tlsVersion) } localhostInsecureRequest() } finally { Security.removeProvider("Conscrypt") client.close() } } @Test fun testRequestUsesPlayProvider() { assumeNetwork() try { try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 27K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
connectSocket() success = true return ConnectResult(plan = this) } catch (e: IOException) { user.connectFailed(route, null, e) return ConnectResult(plan = this, throwable = e) } finally { user.removePlanToCancel(this) if (!success) { rawSocket?.closeQuietly() } } } override fun connectTlsEtc(): ConnectResult {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
mockwebserver/api/mockwebserver3.api
public final fun getPort ()I public final fun getProtocolNegotiationEnabled ()Z public final fun getProtocols ()Ljava/util/List; public final fun getRequestCount ()I public final fun getServerSocketFactory ()Ljavax/net/ServerSocketFactory; public final fun getStarted ()Z public final fun noClientAuth ()V public final fun requestClientAuth ()V public final fun requireClientAuth ()V
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 03 21:59:45 GMT 2023 - 12.7K bytes - Viewed (0) -
gradle/wrapper/gradle-wrapper.jar
validateDistribution; public void WrapperConfiguration(); public final void setDistribution(java.net.URI); public final String getDistributionBase(); public final void setDistributionBase(String); public final String getDistributionPath(); public final void setDistributionPath(String); public final String getDistributionSha25(); public final void setDistributionSha25(String); public final String getZipBase(); public final void setZipBase(String); public final String getZipPath(); public final void setZipPath(String);...
Archive - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Dec 24 09:00:26 GMT 2023 - 42.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
} ?: return logger.logElapsed(task, task.queue!!) { var completedNormally = false try { runTask(task) completedNormally = true } finally { // If the task is crashing start another thread to service the queues. if (!completedNormally) { lock.withLock { startAnotherThread() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
skipBuffer.clear() } true // Success! The source has been exhausted. } catch (_: InterruptedIOException) { false // We ran out of time before exhausting the source. } finally { if (originalDurationNs == Long.MAX_VALUE) { timeout().clearDeadline() } else { timeout().deadlineNanoTime(nowNs + originalDurationNs) } } } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
val startedTask = startNextTask() val otherTasksStarted = startedTask != yieldCompleteTask try { while (currentTask != self) { taskRunner.condition.await() } } finally { serialTaskQueue.remove(yieldCompleteTask) } // If we're yielding until we're exhausted and a task run, keep going until a task doesn't run.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0)