- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for asynchronously (0.18 sec)
-
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
} /** * Indexes a document asynchronously. * * @param request the index request * @return a future for the index response */ @Override public ActionFuture<IndexResponse> index(final IndexRequest request) { return client.index(request); } /** * Indexes a document asynchronously with a callback. *Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 122.4K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java
} catch (final Exception e) { throw new SuggestIndexException("Failed to index from query_string.", e); } } /** * Indexes documents from a query log reader asynchronously. * @param queryLogReader The query log reader. * @param docPerReq The number of documents to process per request. * @param requestInterval The interval between requests.
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Mon Nov 24 03:40:05 UTC 2025 - 34.4K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/util/TemporaryFileInputStreamTest.java
TemporaryFileInputStream stream = new TemporaryFileInputStream(tempFile); stream.read(); // Read some data stream.close(); // Note: FileUtil.deleteInBackground() performs deletion asynchronously, // so we cannot reliably check if file is deleted immediately // This test just verifies that close() completes without error } public void test_emptyFile() throws Exception {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sat Nov 22 13:28:22 UTC 2025 - 7.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java
} saveInfo(messages -> messages.addSuccessBulkProcessStarted(GLOBAL)); return redirect(getClass()); // no-op } /** * Import the file asynchronously. * @param fileName The file name. * @param tempFile The temporary file. */ protected void asyncImport(final String fileName, final File tempFile) { final int fileType;Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Mon Nov 24 02:07:40 UTC 2025 - 32.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 27.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/entraid/EntraIdAuthenticator.java
} /** * Updates the user's group and role membership information with lazy loading for parent groups. * Direct groups are retrieved synchronously, while parent groups are fetched asynchronously * to avoid login delays when users have many nested group memberships. * @param user The Entra ID user to update. */ public void updateMemberOf(final EntraIdUser user) {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 13 02:21:17 UTC 2025 - 56.7K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
*/ @Override public ActionFuture<IndexResponse> index(final IndexRequest request) { return client.index(request); } /** * Executes an index request asynchronously. * * @param request The index request. * @param listener The response listener. */ @OverrideRegistered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Nov 23 02:01:26 UTC 2025 - 26.2K bytes - Viewed (0) -
README.md
- Support for query parameters, headers, body (String or stream), compression, SSL configuration, proxies, and timeouts - Automatic in-memory or on-disk caching of request/response bodies - Synchronous and asynchronous (callback) execution - Minimal dependencies (only Apache Commons IO) ## Installation ### Maven Add the dependency to your `pom.xml` (replace `x.y.z` with the latest version): ```xml <dependency>
Registered: Sat Dec 20 09:13:53 UTC 2025 - Last Modified: Thu Nov 20 13:34:13 UTC 2025 - 2.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/base/login/EntraIdCredential.java
this.roles = roles; } /** * Resets permissions to force recalculation on next getPermissions() call. * This is called after asynchronous parent group lookup completes. */ public void resetPermissions() { this.permissions = null; } }Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 7.8K bytes - Viewed (0) -
CLAUDE.md
3. **Resource Management**: `CurlResponse` implements `Closeable` for try-with-resources 4. **Async Support**: Both synchronous (`executeSync()`) and asynchronous (`execute()`) execution modes ## Technical Details - **Java Version**: 17+ - **Dependencies**: - Apache Commons IO 2.19.0 (runtime) - JUnit 4.13.2 (test) - **Module Name**: `org.codelibs.curl4j`
Registered: Sat Dec 20 09:13:53 UTC 2025 - Last Modified: Mon Nov 24 03:10:07 UTC 2025 - 3.2K bytes - Viewed (0)