- Sort Score
- Num 10 results
- Language All
Results 191 - 200 of 250 for asStream (0.04 seconds)
-
src/main/java/org/codelibs/fess/util/JvmUtil.java
*/ public static String[] filterJvmOptions(final String[] values) { final int version = getJavaVersion(); return Arrays.stream(values).map(s -> { final Matcher matcher = VERSION_PREFIX_PATTERN.matcher(s); if (!matcher.matches()) { return s; }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 2.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/IndexExportJob.java
import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import java.util.Arrays; import java.util.Map; import java.util.Set; import java.util.concurrent.atomic.AtomicLong; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.mylasta.direction.FessConfig; import org.codelibs.fess.opensearch.client.SearchEngineClient;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 10.8K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/crawler/helper/FessMimeTypeHelperTest.java
return ".sql=text/x-sql"; } }); mimeTypeHelper.init(); // Override works even without an input stream assertEquals("text/x-sql", mimeTypeHelper.getContentType(null, "test.sql")); } @Test public void test_getContentType_overridePriority() throws IOException {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Jan 24 09:06:33 GMT 2026 - 12.1K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/it/admin/DocumentsTests.java
// Verify document content for (int i = 0; i < 5; i++) { final String expectedTitle = NAME_PREFIX + i; boolean found = docs.stream().anyMatch(doc -> expectedTitle.equals(doc.get("title"))); assertTrue(found, "Document with title " + expectedTitle + " should exist"); } logger.info("[END] testBulkCreate"); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 9.9K bytes - Click Count (0) -
build-logic/buildquality/src/test/kotlin/gradlebuild/testcleanup/TestFilesCleanupServiceTest.kt
Caused by: java.io.IOException: Failed to delete temp directory /var/folders/_2/vxp7qn2x7qzd0zqqm8p128lh0000gq/T/junit-4205933054320696172. at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) */ .withDebug(true) .withArguments(*args, "--stacktrace", "--no-watch-fs") private
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Feb 10 00:16:44 GMT 2026 - 11.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/reqheader/ApiAdminReqheaderAction.java
*/ package org.codelibs.fess.app.web.api.admin.reqheader; import static org.codelibs.fess.app.web.admin.reqheader.AdminReqheaderAction.getRequestHeader; import java.util.List; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.app.pager.ReqHeaderPager; import org.codelibs.fess.app.service.RequestHeaderService;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 9.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/webauth/ApiAdminWebauthAction.java
*/ package org.codelibs.fess.app.web.api.admin.webauth; import static org.codelibs.fess.app.web.admin.webauth.AdminWebauthAction.getWebAuthentication; import java.util.List; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.app.pager.WebAuthPager; import org.codelibs.fess.app.service.WebAuthenticationService;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 9.1K bytes - Click Count (0) -
.teamcity/scripts/FindCommits.java
import java.io.IOException; import java.io.InputStream; import java.nio.charset.StandardCharsets; import java.util.Arrays; import java.util.List; import java.util.Objects; import java.util.stream.Collectors; /** * TeamCity helper script that prints the list of commits in the current PR (one SHA per line). * * Usage (Java 11+ single-file source execution):
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Jan 20 03:53:25 GMT 2026 - 5.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/dict/kuromoji/KuromojiFile.java
*/ public String getSimpleName() { return new File(path).getName(); } /** * Updates the dictionary file with the given input stream. * * @param in The input stream. * @throws IOException If an I/O error occurs. */ public synchronized void update(final InputStream in) throws IOException {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 20 07:09:00 GMT 2025 - 11.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/util/ErrorToWarnRewritePolicy.java
*/ @PluginFactory public static ErrorToWarnRewritePolicy createPolicy(@PluginAttribute("loggers") final String loggerNamePrefix) { final String[] loggerNames = loggerNamePrefix != null ? Arrays.stream(loggerNamePrefix.split(",")).map(String::trim).filter(s -> s.length() > 0).toArray(n -> new String[n]) : new String[0]; return new ErrorToWarnRewritePolicy(loggerNames); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 3.4K bytes - Click Count (0)