- Sort Score
- Result 10 results
- Languages All
Results 671 - 680 of 697 for Streams (0.08 sec)
-
guava/src/com/google/common/net/MediaType.java
* @since 20.0 */ public static final MediaType NACL_PORTABLE_APPLICATION = createConstant(APPLICATION_TYPE, "x-pnacl"); public static final MediaType OCTET_STREAM = createConstant(APPLICATION_TYPE, "octet-stream"); public static final MediaType OGG_CONTAINER = createConstant(APPLICATION_TYPE, "ogg"); public static final MediaType OOXML_DOCUMENT = createConstant(Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Oct 02 01:46:40 UTC 2025 - 48K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.29.md
- Added a return value to `QueueingHint` to indicate an error. If `QueueingHint` returns an error, the scheduler logs it and treats the event as a `QueueAfterBackoff` so that the Pod won't be stuck in the unschedulable pod pool. ([#119290](https://github.com/kubernetes/kubernetes/pull/119290), [@carlory](https://github.com/carlory))
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Wed Mar 12 00:36:01 UTC 2025 - 429.6K bytes - Viewed (1) -
android/guava-tests/test/com/google/common/collect/MapsTest.java
result = Maps.fromProperties(testProp); assertEquals("true", result.get("first")); assertEquals("null", result.get("second")); assertEquals(2, result.size()); // Now test values loaded from a stream. String props = "test\n second = 2\n Third item : a short phrase "; testProp.load(new StringReader(props)); result = Maps.fromProperties(testProp); assertEquals(4, result.size());
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 22:56:33 UTC 2025 - 62.7K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
final List<T> bufferedList = new ArrayList<>(bulkBufferSize); final StringBuilder failureBuf = new StringBuilder(100); list.stream().forEach(target -> { bufferedList.add(target); if (bufferedList.size() >= bulkBufferSize) { final BulkResponse response = doInsertAll(bufferedList, opType);
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:40:57 UTC 2025 - 34.3K bytes - Viewed (0) -
android/guava/src/com/google/common/primitives/Longs.java
* compares, using {@link #compare(long, long)}), the first pair of values that follow any common * prefix, or when one array is a prefix of the other, treats the shorter array as the lesser. For * example, {@code [] < [1L] < [1L, 2L] < [2L]}. * * <p>The returned comparator is inconsistent with {@link Object#equals(Object)} (since arraysRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Oct 22 18:14:49 UTC 2025 - 29K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
* </pre> * * <p><strong>ReadWriteLocks</strong> * * <p>While {@code ReadWriteLock} instances have different properties and can form cycles without * potential deadlock, this class treats {@code ReadWriteLock} instances as equivalent to * traditional exclusive locks. Although this increases the false positives that the locks detect
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 17:06:34 UTC 2025 - 35.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ImmutableSortedSetTest.java
import java.util.Iterator; import java.util.NoSuchElementException; import java.util.Set; import java.util.SortedSet; import java.util.TreeSet; import java.util.function.BiPredicate; import java.util.stream.Collector; import junit.framework.Test; import junit.framework.TestSuite; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /** * Unit tests for {@link ImmutableSortedSet}. *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 46.7K bytes - Viewed (0) -
guava/src/com/google/common/io/BaseEncoding.java
int len = decodeTo(tmp, chars); return extract(tmp, len); } /** * Returns an {@code InputStream} that decodes base-encoded input from the specified {@code * Reader}. The returned stream throws a {@link DecodingException} upon decoding-specific errors. */ @J2ktIncompatible @GwtIncompatible // Reader,InputStream public abstract InputStream decodingStream(Reader reader); /**
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Oct 06 14:51:47 UTC 2025 - 41.7K bytes - Viewed (0) -
fess-crawler/src/main/resources/org/codelibs/fess/crawler/mime/tika-mimetypes.xml
<mime-type type="application/nss"/> <mime-type type="application/ocsp-request"/> <mime-type type="application/ocsp-response"/> <mime-type type="application/octet-stream"> <magic priority="50"> <match value="#\ This\ is\ a\ shell\ archive" type="string" offset="10"/> <match value="\037\036" type="string" offset="0"/> <match value="017437" type="host16" offset="0"/>Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Oct 16 07:46:32 UTC 2025 - 320.2K bytes - Viewed (5) -
src/main/java/jcifs/internal/smb1/ServerMessageBlock.java
* actually purer. However, in the case of smb we know the * wordCount and byteCount. And since every subclass of * ServerMessageBlock would have to perform the same read * operation on the input stream, we might as will pull that * common functionality into the superclass and read wordCount * and byteCount worth of data. * * We will still use the readXxxWireFormat return values toRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 38.9K bytes - Viewed (0)