- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 385 for dequeue (0.24 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
private val cleanupQueue: TaskQueue = taskRunner.newQueue() private val cleanupTask = object : Task("$okHttpName ConnectionPool connection closer") { override fun runOnce(): Long = closeConnections(System.nanoTime()) } private fun AddressState.scheduleOpener() { queue.schedule( object : Task("$okHttpName ConnectionPool connection opener") {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
*/ public void enqueue(Event<L> event) { enqueueHelper(event, event); } /** * Enqueues an event to be run on currently known listeners, with a label. * * @param event the callback to execute on {@link #dispatch} * @param label a description of the event to use in the case of an error */ public void enqueue(Event<L> event, String label) { enqueueHelper(event, label);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
.github/workflows/team-triage-stale.yml
name: 'Requeue stale team-triage items' on: schedule: # Execute every day at 00:05 to avoid conflicts with other workflows - cron: '5 0 * * *' permissions: {} jobs: requeue: permissions: issues: write pull-requests: write runs-on: ubuntu-latest steps: - uses: actions/stale@v9 with: operations-per-run: 50 remove-stale-when-updated: false
Others - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Thu May 02 09:13:16 GMT 2024 - 835 bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/QueueElementTester.java
public void testElement_empty() { try { getQueue().element(); fail("emptyQueue.element() should throw"); } catch (NoSuchElementException expected) { } expectUnchanged(); } @CollectionSize.Require(ONE) public void testElement_size1() { assertEquals("size1Queue.element() should return first element", e0(), getQueue().element()); expectUnchanged(); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Jan 09 20:10:38 GMT 2018 - 2.3K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/QueueOfferTester.java
public void testOffer_supportedNotPresent() { assertTrue("offer(notPresent) should return true", getQueue().offer(e3())); expectAdded(e3()); } @CollectionFeature.Require({SUPPORTS_ADD, ALLOWS_NULL_VALUES}) public void testOffer_nullSupported() { assertTrue("offer(null) should return true", getQueue().offer(null)); expectAdded((E) null); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 2.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/testers/QueueRemoveTester.java
try { getQueue().remove(); fail("emptyQueue.remove() should throw"); } catch (NoSuchElementException expected) { } expectUnchanged(); } @CollectionFeature.Require(SUPPORTS_REMOVE) @CollectionSize.Require(ONE) public void testRemove_size1() { assertEquals("size1Queue.remove() should return first element", e0(), getQueue().remove()); expectMissing(e0()); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 2.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
dispatcher.maxRequests = 2 client.newCall(newRequest("http://a/1")).enqueue(callback) client.newCall(newRequest("http://b/1")).enqueue(callback) client.newCall(newRequest("http://c/1")).enqueue(callback) client.newCall(newRequest("http://a/2")).enqueue(callback) client.newCall(newRequest("http://b/2")).enqueue(callback) dispatcher.maxRequests = 4
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
@Test fun connectionPooling_Async() { server.enqueue(MockResponse(body = "abc")) server.enqueue(MockResponse(body = "def")) server.enqueue(MockResponse(body = "ghi")) client.newCall(Request.Builder().url(server.url("/a")).build()).enqueue(callback) callback.await(server.url("/a")).assertBody("abc") client.newCall(Request.Builder().url(server.url("/b")).build()).enqueue(callback)
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/src/test/java/okhttp3/internal/tls/CertificatePinnerChainValidationTest.kt
.heldCertificate(certificate, intermediateCa.certificate) .build() server.useHttps(serverHandshakeCertificates.sslSocketFactory()) // The request should complete successfully. server.enqueue( MockResponse.Builder() .body("abc") .build(), ) val call1 = client.newCall( Request.Builder() .url(server.url("/")) .build(),
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 23.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.9K bytes - Viewed (0)