- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 170 for dequeue (0.2 sec)
-
cni/pkg/nodeagent/informers.go
systemNamespace string queue controllers.Queue pods kclient.Client[*corev1.Pod] namespaces kclient.Client[*corev1.Namespace] } func setupHandlers(ctx context.Context, kubeClient kube.Client, dataplane MeshDataplane, systemNamespace string) *InformerHandlers { s := &InformerHandlers{ctx: ctx, dataplane: dataplane, systemNamespace: systemNamespace} s.queue = controllers.NewQueue("ambient",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
ListenerCallQueue<Object> queue = new ListenerCallQueue<>(); queue.addListener(listener, directExecutor()); Multiset<Object> counters = ConcurrentHashMultiset.create(); queue.enqueue(incrementingEvent(counters, listener, 1)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 2)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 3));
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 8.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
* calls returns to zero). * * Note: The time at which a [call][Call] is considered idle is different depending on whether it * was run [asynchronously][Call.enqueue] or [synchronously][Call.execute]. Asynchronous calls * become idle after the [onResponse][Callback.onResponse] or [onFailure][Callback.onFailure]
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
ListenerCallQueue<Object> queue = new ListenerCallQueue<>(); queue.addListener(listener, directExecutor()); Multiset<Object> counters = ConcurrentHashMultiset.create(); queue.enqueue(incrementingEvent(counters, listener, 1)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 2)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 3));
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 8.2K bytes - Viewed (0) -
src/main/config/es/fess_config_thumbnail_queue.json
Json - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Dec 02 13:14:56 GMT 2021 - 903 bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/testers/AbstractQueueTester.java
import java.util.Queue; import org.junit.Ignore; /** * Base class for queue collection tests. * * @author Jared Levy */ @GwtCompatible @Ignore // Affects only Android test runner, which respects JUnit 4 annotations on JUnit 3 tests. public class AbstractQueueTester<E> extends AbstractCollectionTester<E> { protected final Queue<E> getQueue() { return (Queue<E>) collection; }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jan 09 20:10:38 GMT 2018 - 1.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/AbstractQueueTester.java
import java.util.Queue; import org.junit.Ignore; /** * Base class for queue collection tests. * * @author Jared Levy */ @GwtCompatible @Ignore // Affects only Android test runner, which respects JUnit 4 annotations on JUnit 3 tests. public class AbstractQueueTester<E> extends AbstractCollectionTester<E> { protected final Queue<E> getQueue() { return (Queue<E>) collection; }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Jan 09 20:10:38 GMT 2018 - 1.1K bytes - Viewed (0) -
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 Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Jan 09 20:10:38 GMT 2018 - 2.3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/testers/QueuePeekTester.java
@CollectionSize.Require(ZERO) public void testPeek_empty() { assertNull("emptyQueue.peek() should return null", getQueue().peek()); expectUnchanged(); } @CollectionSize.Require(ONE) public void testPeek_size1() { assertEquals("size1Queue.peek() should return first element", e0(), getQueue().peek()); expectUnchanged(); } @CollectionFeature.Require(KNOWN_ORDER) @CollectionSize.Require(SEVERAL)
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Jan 09 20:10:38 GMT 2018 - 2.1K bytes - Viewed (0) -
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 Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 2.1K bytes - Viewed (0)