- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 87 for Moll (0.16 sec)
-
guava-testlib/src/com/google/common/collect/testing/testers/QueuePollTester.java
public void testPoll_empty() { assertNull("emptyQueue.poll() should return null", getQueue().poll()); expectUnchanged(); } @CollectionFeature.Require(SUPPORTS_REMOVE) @CollectionSize.Require(ONE) public void testPoll_size1() { assertEquals("size1Queue.poll() should return first element", e0(), getQueue().poll()); expectMissing(e0()); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 2.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/RenderDataUtil.java
} else { if ((value instanceof final Collection<?> coll) && !coll.isEmpty()) { // care performance for List that the most frequent pattern final Object first = coll instanceof List<?> ? ((List<?>) coll).get(0) : coll.iterator().next(); if (first instanceof Entity) { data.register(key, coll.stream().map(BeanUtil::copyBeanToNewMap).collect(Collectors.toList()));
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 1.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
while (added < numElements) { // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple // elements already available (e.g. LinkedBlockingQueue#drainTo locks only once) added += q.drainTo(buffer, numElements - added); if (added < numElements) { // not enough elements immediately available; will have to poll E e = q.poll(deadline - System.nanoTime(), TimeUnit.NANOSECONDS);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 16K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/QueuePollTester.java
public void testPoll_empty() { assertNull("emptyQueue.poll() should return null", getQueue().poll()); expectUnchanged(); } @CollectionFeature.Require(SUPPORTS_REMOVE) @CollectionSize.Require(ONE) public void testPoll_size1() { assertEquals("size1Queue.poll() should return first element", e0(), getQueue().poll()); expectMissing(e0()); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 2.3K bytes - Viewed (0) -
docs/de/docs/advanced/openapi-callbacks.md
Sie wissen jedoch bereits, wie Sie mit **FastAPI** ganz einfach eine automatische Dokumentation für eine API erstellen. Daher werden wir dasselbe Wissen nutzen, um zu dokumentieren, wie die *externe API* aussehen sollte ... indem wir die *Pfadoperation(en)* erstellen, welche die externe API implementieren soll (die, welche Ihre API aufruft). !!! tip "Tipp"
Plain Text - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Sat Mar 30 20:17:23 GMT 2024 - 8.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/crypto/CachedCipher.java
} catch (final UnsupportedEncodingException e) { throw new UnsupportedEncodingRuntimeException(e); } } protected Cipher pollEncryptoCipher() { Cipher cipher = encryptoQueue.poll(); if (cipher == null) { final SecretKeySpec sksSpec = new SecretKeySpec(key.getBytes(), algorithm); try { cipher = Cipher.getInstance(algorithm);
Java - Registered: Fri Apr 26 20:58:09 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
* like [poll]. It is only usable within task faker tasks. */ private inner class TaskFakerBlockingQueue<T>( val delegate: BlockingQueue<T>, ) : AbstractQueue<T>(), BlockingQueue<T> { override val size: Int = delegate.size private var editCount = 0 override fun poll(): T = delegate.poll() override fun poll( timeout: Long, unit: TimeUnit,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 12.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
while (true) { val action = actions.poll() ?: break action(stream) } } } return@FutureTask null } } /** Returns once all stream actions complete successfully. */ fun awaitSuccess() { val futureTask = results.poll(5, TimeUnit.SECONDS) ?: throw AssertionError("no onRequest call received")
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
cmd/site-replication-metrics.go
LastOnline time.Time `json:"lastOnline"` Online bool `json:"isOnline"` Latency madmin.LatencyStat `json:"latency"` // replication metrics across buckets roll up ReplicatedSize int64 `json:"replicatedSize"` // Total number of completed operations ReplicatedCount int64 `json:"replicatedCount"` // Failed captures replication errors in various time windows
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
assertEquals(1, (int) mmHeap.peek()); assertEquals(1, (int) mmHeap.poll()); assertEquals(3, (int) mmHeap.peekLast()); assertEquals(2, (int) mmHeap.peek()); assertEquals(2, (int) mmHeap.poll()); assertEquals(3, (int) mmHeap.peekLast()); assertEquals(3, (int) mmHeap.peek()); assertEquals(3, (int) mmHeap.poll()); assertNull(mmHeap.peekLast()); assertNull(mmHeap.peek());
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 36.1K bytes - Viewed (0)