- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 228 for dequeue (0.05 sec)
-
src/main/java/org/codelibs/core/misc/DisposableUtil.java
import static org.codelibs.core.collection.CollectionsUtil.newLinkedList; import static org.codelibs.core.misc.AssertionUtil.assertArgumentNotNull; import java.beans.Introspector; import java.util.Deque; /** * Utility class for disposing of resources at the end of an application. * <p> * If there are resources that must be disposed of at the end of the application,
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 3K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/OpenJSSETest.kt
@StartStop private val server = MockWebServer() @BeforeEach fun setUp() { platform.assumeOpenJSSE() } @Test fun testTlsv13Works() { enableTls() server.enqueue(MockResponse(body = "abc")) val request = Request(server.url("/")) val response = client.newCall(request).execute() response.use { assertEquals(200, response.code)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 3.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
return getResponseWithInterceptorChain() } finally { client.dispatcher.finished(this) } } override fun enqueue(responseCallback: Callback) { check(executed.compareAndSet(false, true)) { "Already Executed" } callStart() client.dispatcher.enqueue(AsyncCall(responseCallback)) } override fun isExecuted(): Boolean = executed.get() private fun callStart() {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 17.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Interceptor.kt
* * Other exception types cancel the current call: * * * For synchronous calls made with [Call.execute], the exception is propagated to the caller. * * * For asynchronous calls made with [Call.enqueue], an [IOException] is propagated to the caller * indicating that the call was canceled. The interceptor's exception is delivered to the current
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/tls/BasicCertificateChainCleaner.kt
*/ @Throws(SSLPeerUnverifiedException::class) override fun clean( chain: List<Certificate>, hostname: String, ): List<Certificate> { val queue: Deque<Certificate> = ArrayDeque(chain) val result = mutableListOf<Certificate>() result.add(queue.removeFirst()) var foundTrustedCertificate = false followIssuerChain@ for (c in 0 until MAX_SIGNERS) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 4.8K bytes - Viewed (0) -
docs/fr/docs/features.md
Vous aurez des propositions de complétion que vous n'auriez jamais imaginées. Par exemple la clé `prix` dans le corps d'un document JSON (qui est peut-être imbriqué) venant d'une requête. Plus jamais vous ne vous tromperez en tapant le nom d'une clé, vous ne ferez des aller-retour entre votre code et la documentation ou vous ne scrollerez de haut en bas afin d'enfin savoir si vous devez taper `username` ou `user_name`.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 11.1K bytes - Viewed (0) -
docs/fr/docs/alternatives.md
Il est conçu pour avoir des fonctions qui reçoivent deux paramètres, une "requête" et une "réponse". Ensuite, vous "lisez" des parties de la requête et "écrivez" des parties dans la réponse. En raison de cette conception, il n'est pas possible de déclarer des paramètres de requête et des corps avec des indications de type Python standard comme paramètres de fonction.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sat Nov 09 16:39:20 UTC 2024 - 27.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
if (connection.noNewExchanges) { assertThat(eventSequence).matchesPredicate { deque -> deque.any { it is NoNewExchanges && it.connection == connection } } } } logEvent(ConnectionEvent.ConnectionReleased(System.nanoTime(), connection, call)) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 5.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FailingCall.kt
*/ 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") override fun cancel(): Unit = error("unexpected") override fun isExecuted(): Boolean = error("unexpected")
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 1.1K bytes - Viewed (0) -
maven-tests/src/test/java/com/squareup/okhttp3/maventest/AppTest.java
/** * Unit test for simple App. */ public class AppTest { private final MockWebServer mockWebServer = new MockWebServer(); @Test public void testApp() throws IOException { mockWebServer.enqueue(new MockResponse(200, Headers.of(), "Hello, Maven!")); mockWebServer.start(); new SampleHttpClient().makeCall(mockWebServer.url("/")); }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jul 12 12:05:57 UTC 2025 - 1.1K bytes - Viewed (0)