- Sort Score
- Result 10 results
- Languages All
Results 631 - 640 of 1,030 for stream (0.18 sec)
-
impl/maven-core/src/test/java/org/apache/maven/configuration/DefaultBeanConfiguratorPathTest.java
* KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ package org.apache.maven.configuration; import javax.xml.stream.XMLStreamException; import java.io.File; import java.io.StringReader; import java.nio.file.Path; import java.nio.file.Paths; import org.apache.maven.api.xml.XmlService;
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Tue Mar 25 09:45:07 UTC 2025 - 3.7K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Queue; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.fess.crawler.Constants;
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:40:57 UTC 2025 - 16.9K bytes - Viewed (1) -
src/test/java/jcifs/internal/smb2/lease/DirectoryLeaseManagerTest.java
// Verify the cached files have correct names List<DirectoryCacheEntry.FileInfo> children = cacheEntry.getChildren(); assertTrue(children.stream().anyMatch(f -> "file1.txt".equals(f.getName()))); assertTrue(children.stream().anyMatch(f -> "dir1".equals(f.getName()))); } @Test public void testUpdateDirectoryCache() throws IOException { String directoryPath = "/test/dir";Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 01:47:47 UTC 2025 - 15.9K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/plugin/internal/DefaultPluginValidationManager.java
import java.util.LinkedHashMap; import java.util.LinkedHashSet; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.stream.Collectors; import org.apache.maven.api.Constants; import org.apache.maven.eventspy.AbstractEventSpy; import org.apache.maven.execution.ExecutionEvent; import org.apache.maven.execution.MavenSession;
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Sat Apr 05 11:52:32 UTC 2025 - 17.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
* layer primitives: connections, requests, responses, and streams. * * This class supports [asynchronous canceling][cancel]. This is intended to have the smallest * blast radius possible. If an HTTP/2 stream is active, canceling will cancel that stream but not * the other streams sharing its connection. But if the TLS handshake is still in progress then * canceling may break the entire connection.
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Nov 05 18:28:35 UTC 2025 - 19.7K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Optional.java
* <p><b>Comparison to {@code java.util.Optional}:</b> this method has no equivalent in Java 8's * {@code Optional} class; use {@code * optionals.stream().filter(Optional::isPresent).map(Optional::get)} instead. * * <p><b>Java 9 users:</b> use {@code optionals.stream().flatMap(Optional::stream)} instead. * * @since 11.0 (generics widened in 13.0) */ public static <T> Iterable<T> presentInstances(Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Jun 04 13:03:16 UTC 2025 - 15.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
import java.util.logging.Level; import java.util.logging.Logger; import java.util.regex.MatchResult; import java.util.regex.Matcher; import java.util.regex.Pattern; import java.util.stream.Stream; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /** * Supplies an arbitrary "default" instance for a wide range of types, often useful in testing * utilities. *
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 17:50:58 UTC 2025 - 21.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableBiMap.java
import java.util.Arrays; import java.util.Collection; import java.util.Comparator; import java.util.Map; import java.util.function.BinaryOperator; import java.util.function.Function; import java.util.stream.Collector; import java.util.stream.Collectors; import org.jspecify.annotations.Nullable; /** * A {@link BiMap} whose contents will never change, with many other important properties detailed * at {@link ImmutableCollection}. *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 22.2K bytes - Viewed (0) -
tensorflow/c/c_api_macros_internal.h
// `struct_size` is used for struct member compatibility check between core TF // and plug-ins with the same C API minor version. More info here: // https://github.com/tensorflow/community/blob/master/rfcs/20200612-stream-executor-c-api/C_API_versioning_strategy.md #define TF_VALIDATE_STRUCT_SIZE(STRUCT_NAME, STRUCT_OBJ, SIZE_VALUE_NAME) \ do { \
Registered: Tue Dec 30 12:39:10 UTC 2025 - Last Modified: Mon Mar 13 17:40:56 UTC 2023 - 2.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/design/AdminDesignAction.java
return null; } validate(form, messages -> {}, this::asListHtml); verifyTokenKeep(this::asListHtml); return asStream(file.getName()).contentTypeOctetStream().stream(out -> { try (FileInputStream fis = new FileInputStream(file)) { out.write(fis); } }); } /** * Delete a design file.Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 17.4K bytes - Viewed (0)