- Sort Score
- Result 10 results
- Languages All
Results 991 - 1000 of 1,022 for Streams (0.04 sec)
-
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) -
docs/de/docs/alternatives.md
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Oct 11 17:48:49 UTC 2025 - 27.4K bytes - Viewed (0) -
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) -
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) -
cmd/erasure-server-pool.go
return &GetObjectReader{ ObjInfo: objInfo, }, toObjectErr(errMethodNotAllowed, bucket, object) } return nil, err } // check preconditions before reading the stream. if checkPrecondFn != nil && checkPrecondFn(objInfo) { return nil, PreConditionFailed{} } opts.NoLock = true gr, err = z.serverPools[zIdx].GetObjectNInfo(ctx, bucket, object, rs, h, opts)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 89.2K 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) -
cmd/bucket-lifecycle.go
// storage specified by the transition ARN, the metadata is left behind on source cluster and original content // is moved to the transition tier. Note that in the case of encrypted objects, entire encrypted stream is moved // to the transition tier without decrypting or re-encrypting. func transitionObject(ctx context.Context, objectAPI ObjectLayer, oi ObjectInfo, lae lcAuditEvent) (err error) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 33.7K bytes - Viewed (0) -
docs/en/docs/alternatives.md
Using it led to the creation of several Flask full-stack generators. These are the main stacks I (and several external teams) have been using up to now: * <a href="https://github.com/tiangolo/full-stack" class="external-link" target="_blank">https://github.com/tiangolo/full-stack</a>
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Oct 11 17:48:49 UTC 2025 - 23.6K bytes - Viewed (0)