- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for forEach (0.14 sec)
-
README.md
.setQuery("sea") // user input .setSize(10) // max suggestions .execute() .getResponse(); // Process suggestions response.getItems().forEach(item -> { System.out.println("Suggestion: " + item.getText()[0]); System.out.println("Score: " + item.getScore()); }); ``` #### 4. Asynchronous Suggestions ```java suggester.suggest()
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sun Aug 31 03:31:14 UTC 2025 - 12.1K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
stream(ComponentUtil.getVirtualHostHelper().getVirtualHostPaths()) .of(stream -> stream.filter(s -> s != null && !"/".equals(s)).forEach(key -> { designJspFileNameMap.entrySet().stream().forEach(e -> { final File jspFile = getDesignJspFile("/WEB-INF/view" + key + "/" + e.getValue()); if (!jspFile.exists()) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 36.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
if (StringUtil.isNotBlank(httpAddress)) { System.setProperty(Constants.FESS_SEARCH_ENGINE_HTTP_ADDRESS, httpAddress); } waitForYellowStatus(fessConfig); indexConfigList.forEach(configName -> { final String[] values = configName.split("/"); if (values.length == 2) { final String configIndex = values[0]; final String configType = values[1];
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 121.9K bytes - Viewed (1) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
connections.forEach(conn -> { try { conn.disconnect(true, true); } catch (Exception e) { log.debug("Error closing connection: {}", e.getMessage()); } }); connections.clear(); nonPooledConnections.forEach(conn -> { try { conn.disconnect(true, true);Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 33.4K bytes - Viewed (0) -
docs/en/docs/js/termynal.js
*/ if (document.currentScript.hasAttribute('data-termynal-container')) { const containers = document.currentScript.getAttribute('data-termynal-container'); containers.split('|') .forEach(container => new Termynal(container))
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 10:32:57 UTC 2025 - 9.3K bytes - Viewed (0) -
README.md
try (InputStream input = ResourceUtil.getResourceAsStream("data.txt")) { String content = InputStreamUtil.getUTF8String(input); } // Resource traversal for processing multiple files ResourceTraversalUtil.forEach("META-INF", (resource, is) -> { // Process each resource in the META-INF directory System.out.println("Processing: " + resource); }); ``` ### Text Processing and JSON ```java
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Sun Aug 31 02:56:02 UTC 2025 - 12.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb/SmbClient.java
} super.init(); final Properties props = new Properties(); System.getProperties().entrySet().stream().filter(e -> e.getKey().toString().startsWith("jcifs.")).forEach(e -> { props.setProperty((String) e.getKey(), (String) e.getValue()); }); try { cifsContext = new BaseContext(new PropertyConfiguration(props));Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Sep 18 09:30:45 UTC 2025 - 22.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/lease/LeaseManager.java
leases.entrySet() .stream() .sorted((e1, e2) -> Long.compare(e1.getValue().getLastAccessTime(), e2.getValue().getLastAccessTime())) .limit(count) .forEach(entry -> { Smb2LeaseKey key = entry.getKey(); LeaseEntry lease = entry.getValue(); log.info("Evicting lease for path: {} due to max lease limit", lease.getPath());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 18.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java
break; } final BulkRequestBuilder bulkRequestBuiler = client.prepareBulk(); Stream.of(hits).map(SearchHit::getId).forEach(id -> bulkRequestBuiler.add(new DeleteRequest(index, id))); final BulkResponse bulkResponse = bulkRequestBuiler.execute().actionGet(settings.getBulkTimeout());Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Mon Sep 01 13:33:03 UTC 2025 - 17.4K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
get(c -> c.admin().cluster().prepareHealth(targetIndices).setWaitForYellowStatus().execute()); if (!healthResponse.isTimedOut()) { onConnectListenerList.forEach(l -> { try { l.onConnect(); } catch (final Exception e) { logger.warn("Failed to invoke " + l, e); } });
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Aug 31 05:32:52 UTC 2025 - 25.3K bytes - Viewed (0)