- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 228 for dequeue (0.03 sec)
-
guava-testlib/src/com/google/common/collect/testing/testers/AbstractQueueTester.java
@SuppressWarnings("JUnit4ClassUsedInJUnit3") public class AbstractQueueTester<E> extends AbstractCollectionTester<E> { protected final Queue<E> getQueue() { return (Queue<E>) collection; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Nov 14 23:40:07 UTC 2024 - 1.3K bytes - Viewed (0) -
docs/fr/docs/index.md
* La documentation alternative reflétera également le nouveau paramètre de requête et le nouveau corps :  ### En résumé En résumé, vous déclarez **une fois** les types de paramètres, <abbr title="en anglais : body">le corps</abbr> de la requête, etc. en tant que paramètres de fonction. Vous faites cela avec les types Python standard modernes.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 10:49:48 UTC 2025 - 22K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/QueueDispatcher.kt
override fun peek(): MockResponse = throw UnsupportedOperationException("unexpected call") fun enqueueResponse(response: MockResponse) { delegate.enqueue(response.wrap()) } override fun shutdown() { delegate.close() } fun setFailFast(failFast: Boolean) { delegate.setFailFast(failFast) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 14 16:09:26 UTC 2025 - 1.3K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskLogger.kt
startNs = queue.taskRunner.backend.nanoTime() log(task, queue, "starting") } var completedNormally = false try { val result = block() completedNormally = true return result } finally { if (loggingEnabled) { val elapsedNs = queue.taskRunner.backend.nanoTime() - startNs if (completedNormally) { log(task, queue, "finished run in ${formatDuration(elapsedNs)}")
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.6K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/AsynchronousGet.kt
private val client = OkHttpClient() fun run() { val request = Request .Builder() .url("http://publicobject.com/helloworld.txt") .build() client.newCall(request).enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { e.printStackTrace() } override fun onResponse(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.6K bytes - Viewed (0) -
native-image-tests/src/test/kotlin/okhttp3/nativeimage/SampleTest.kt
private val client = OkHttpClient() @Test fun passingTest() { assertThat("hello").isEqualTo("hello") } @Test fun testMockWebServer() { server.enqueue(MockResponse(body = "abc")) server.start() client.newCall(Request(url = server.url("/"))).execute().use { assertThat(it.body.string()).isEqualTo("abc") } } @Test
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 22 20:31:49 UTC 2025 - 1.4K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/DevServer.kt
class DevServer { val handshakeCertificates = TlsUtil.localhost() val server = MockWebServer().apply { useHttps(handshakeCertificates.sslSocketFactory(), false) enqueue( MockResponse() .setResponseCode(HTTP_MOVED_TEMP) .setHeader("Location", "https://www.google.com/robots.txt"), ) } val clientCertificates = HandshakeCertificates
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.9K bytes - Viewed (0) -
samples/compare/src/test/kotlin/okhttp3/compare/JettyHttpClientTest.kt
@StartStop private val server = MockWebServer() @BeforeEach fun setUp() { client.start() } @AfterEach fun tearDown() { client.stop() } @Test fun get() { server.enqueue(MockResponse(body = "hello, Jetty HTTP Client")) val request = client .newRequest(server.url("/").toUri()) .header("Accept", "text/plain") val response = request.send()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 2.1K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt
unit: TimeUnit, ): RecordedRequest? = delegate.takeRequest(timeout, unit)?.unwrap() @JvmName("-deprecated_requestCount") fun getRequestCount(): Int = delegate.requestCount fun enqueue(response: MockResponse) { delegate.enqueue(response.wrap()) } @Throws(IOException::class) @JvmOverloads fun start(port: Int = 0) { started = true delegate.start(port) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 00:19:42 UTC 2025 - 4.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java
* } * </pre> */ public class ESSourceReader implements DocumentReader { private static final Logger logger = LogManager.getLogger(ESSourceReader.class); /** Queue of documents. */ protected final Queue<Map<String, Object>> queue = new ConcurrentLinkedQueue<>(); /** Flag indicating if reading is finished. */ protected final AtomicBoolean isFinished = new AtomicBoolean(false); /** Random number generator. */
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 11K bytes - Viewed (0)