- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 1,102 for Stream (1.37 sec)
-
api/maven-api-cli/src/main/java/org/apache/maven/api/cli/InvokerRequest.java
/** * Returns the input stream for the Maven execution, if running in embedded mode. * * @return an {@link Optional} containing the input stream, or empty if not applicable */ @Nonnull default Optional<InputStream> stdIn() { return Optional.ofNullable(parserRequest().stdIn()); } /** * Returns the output stream for the Maven execution, if running in embedded mode.Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Jun 11 13:14:09 UTC 2025 - 6.7K bytes - Viewed (0) -
guava/src/com/google/common/primitives/ImmutableIntArray.java
} /** * Returns an immutable array containing all the values from {@code stream}, in order. * * @since 22.0 (but only since 33.4.0 in the Android flavor) */ public static ImmutableIntArray copyOf(IntStream stream) { // Note this uses very different growth behavior from copyOf(Iterable) and the builder. int[] array = stream.toArray(); return (array.length == 0) ? EMPTY : new ImmutableIntArray(array); }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Dec 12 14:49:24 UTC 2025 - 21.5K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/extractor/impl/EXTRACTOR_TESTS_README.md
- ✅ Failed extraction includes descriptive error messages - ✅ Null input stream validation - ✅ Error messages include file type context --- ### 2. FilenameExtractorEnhancedTest.java **Purpose**: Test FilenameExtractor edge cases and new documentation. **Key Test Areas**: - Parameter handling (null, empty, missing) - Special character handling - Input stream validation (not consumption) - Edge cases (long filenames, paths, whitespace)
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Wed Nov 19 08:55:01 UTC 2025 - 5.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/EnumBiMap.java
*/ @GwtIncompatible // java.io.ObjectOutputStream private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(keyTypeOrObjectUnderJ2cl); stream.writeObject(valueTypeOrObjectUnderJ2cl); Serialization.writeMap(this, stream); } @SuppressWarnings("unchecked") // reading fields populated by writeObject
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 15:50:50 UTC 2025 - 6.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/NotificationHelper.java
if (StringUtil.isBlank(slackWebhookUrls)) { return; } final String body = toSlackMessage(discloser); StreamUtil.split(slackWebhookUrls, "[,\\s]").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(url -> { try (CurlResponse response = Curl.post(url).header("Content-Type", "application/json").body(body).execute()) { if (response.getHttpStatusCode() == 200) {
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 6.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/GroupService.java
}); userBhv.selectCursor(cb -> cb.query().setGroups_Equal(group.getId()), entity -> { entity.setGroups( stream(entity.getGroups()).get(stream -> stream.filter(s -> !s.equals(group.getId())).toArray(n -> new String[n]))); userBhv.insertOrUpdate(entity); }); } /**Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 5.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/search/SearchAction.java
} } form.fields.entrySet().stream().filter(e -> e.getValue() != null).forEach(e -> { final String key = LaFunctions.u(e.getKey()); stream(e.getValue()).of(stream -> stream.filter(StringUtil::isNotBlank) .forEach(s -> pagingQueryList.add("fields." + key + "=" + LaFunctions.u(s)))); }); form.as.entrySet().stream().filter(e -> e.getValue() != null).forEach(e -> {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 14K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/AccessTokenService.java
} stream(accessToken.getPermissions()).of(stream -> stream.forEach(permissionSet::add)); final String name = accessToken.getParameterName(); stream(request.getParameterValues(name)).of(stream -> stream.filter(StringUtil::isNotBlank).forEach(permissionSet::add)); return OptionalEntity.of(permissionSet);Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 5.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Aug 02 20:36:00 UTC 2025 - 40.3K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/WriterUtil.java
*/ protected WriterUtil() { } /** * Creates a {@link Writer} to output to a stream with the specified encoding. * * @param os the stream (must not be {@literal null}) * @param encoding the encoding (must not be {@literal null} or empty) * @return a {@link Writer} to output to the stream */ public static Writer create(final OutputStream os, final String encoding) {Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 3K bytes - Viewed (0)