- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for reserve (0.02 sec)
-
src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java
Thread th = new Thread(() -> { try { Thread.sleep(1000); } catch (InterruptedException ignore) {} deferred.resolve(new SuggestResponse("", 0, Collections.emptyList(), 0, null)); }); th.start(); final CountDownLatch latch = new CountDownLatch(1); deferred.promise().then(response -> latch.countDown());Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sat Mar 15 06:51:20 UTC 2025 - 4.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/conn/IdnDnsResolver.java
* The host name is first converted to ASCII using IDN before resolution. * * @param host the host name to resolve * @return an array of IP addresses for the host * @throws UnknownHostException if the host name cannot be resolved */ @Override public InetAddress[] resolve(final String host) throws UnknownHostException { return InetAddress.getAllByName(toAscii(host)); } /**Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 3.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java
* It is similar to a Promise in JavaScript. * It allows you to register callbacks that will be executed when the computation is complete, * either successfully (resolve) or with an error (reject). * </p> * * <p> * The Deferred class has a Promise inner class that allows you to register callbacks * to be executed when the computation is complete.
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Fri Jul 04 14:00:23 UTC 2025 - 7.8K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/NumberConcatenationFilterFactory.java
super(indexSettings, name, settings); final String suffixWordsPath = settings.get("suffix_words_path"); if (suffixWordsPath != null) { final File suffixWordsFile = environment.configDir().resolve(suffixWordsPath).toFile(); try (Reader reader = IOUtils.getDecodingReader(new FileInputStream(suffixWordsFile), StandardCharsets.UTF_8)) { suffixWords = WordlistLoader.getWordSet(reader);
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sun May 18 02:59:16 UTC 2025 - 2.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/request/Request.java
} return deferred.promise(); } /** * Processes the request. * @param client The OpenSearch client. * @param deferred The Deferred object to resolve or reject the response. */ protected abstract void processRequest(Client client, Deferred<T> deferred); /** * Returns a validation error message, or null if there are no errors.Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Fri Jul 04 14:00:23 UTC 2025 - 2.2K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/SynonymLoader.java
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sun May 18 02:59:16 UTC 2025 - 6.7K bytes - Viewed (1) -
src/test/java/org/codelibs/opensearch/extension/analysis/ReloadableKeywordMarkerFilterFactory.java
final Settings settings) { super(indexSettings, name, settings); final String path = settings.get("keywords_path"); if (path != null) { keywordPath = environment.configDir().resolve(path); } else { keywordPath = null; } reloadInterval = settings.getAsTime("reload_interval", TimeValue.timeValueMinutes(1)).getMillis(); } @OverrideRegistered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sun May 18 02:59:16 UTC 2025 - 2K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/ReloadableStopFilterFactory.java
final Settings settings) { super(indexSettings, name, settings); final String path = settings.get("stopwords_path"); if (path != null) { stopwordPath = environment.configDir().resolve(path); } else { stopwordPath = null; } ignoreCase = settings.getAsBoolean("ignore_case", false);Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sun May 18 02:59:16 UTC 2025 - 2.1K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/UrlConvertHelper.java
* URLs using these rules.</p> * * <p>The conversion is performed by iterating through the conversion map and applying * each replacement rule sequentially. The order of the rules in the map is preserved * during the conversion process.</p> * * <p>Example usage:</p> * * <pre>{@code * UrlConvertHelper helper = new UrlConvertHelper(); * helper.add("old-domain.com", "new-domain.com");
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 3.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/request/popularwords/PopularWordsRequest.java
deferred.reject(new SuggesterException("Search failure. Failed shards num:" + searchResponse.getFailedShards())); } else { deferred.resolve(createResponse(searchResponse)); } } @Override public void onFailure(final Exception e) { deferred.reject(e); } });
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 9.2K bytes - Viewed (0)