- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 27 for Promise (0.06 seconds)
-
src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java
// All should be the same promise instance assertEquals("Promise chain should return same instance", promise1, promise2); assertEquals("Promise chain should return same instance", promise2, promise3); } @Test public void test_promiseFromDeferredThen() throws Exception {Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Feb 01 12:48:24 GMT 2026 - 21.1K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/suggest/index/SuggestIndexerErrorHandlingTest.java
AtomicReference<Throwable> errorRef = new AtomicReference<>(); Deferred<SuggestIndexResponse>.Promise promise = suggester.indexer().indexFromQueryLog(emptyReader, 10, 0); promise.then(response -> { responseRef.set(response); latch.countDown(); }).error(error -> { errorRef.set(error);
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sat Mar 14 02:35:38 GMT 2026 - 18.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/request/Request.java
*/ public Request() { // nothing } /** * Executes the request. * @param client The OpenSearch client. * @return A Promise that will be resolved with the response or rejected with an error. */ public Deferred<T>.Promise execute(final Client client) { final String error = getValidationError(); if (!Strings.isNullOrEmpty(error)) {Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Nov 23 11:21:40 GMT 2025 - 2.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/index/operations/ContentIndexingOperations.java
* @param docPerReq The number of documents to process per request * @param requestInterval The interval between requests * @return A Promise that will be resolved with the SuggestIndexResponse */ public Deferred<SuggestIndexResponse>.Promise indexFromQueryLog(final ContentIndexingContext ctx, final QueryLogReader queryLogReader, final int docPerReq, final long requestInterval) {Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sat Mar 14 02:35:38 GMT 2026 - 21.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java
* @param docPerReq The number of documents to process per request. * @param requestInterval The interval between requests. * @return A Promise that will be resolved with the SuggestIndexResponse or rejected with an error. */ public Deferred<SuggestIndexResponse>.Promise indexFromQueryLog(final QueryLogReader queryLogReader, final int docPerReq, final long requestInterval) { ensureOperations();Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sat Mar 14 02:35:38 GMT 2026 - 20.9K bytes - Click Count (0) -
CLAUDE.md
├── concurrent/ # Async patterns (Deferred/Promise) └── util/ # Utilities ``` ### Key Design Patterns - **Builder**: SuggesterBuilder, SuggestRequestBuilder - **Facade**: Suggester (main entry point) - **Composite**: NormalizerChain, ReadingConverterChain - **Strategy**: Normalizer, ReadingConverter, ContentsParser - **Deferred/Promise**: Async operations ### Index Alias Strategy
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Thu Mar 12 03:39:53 GMT 2026 - 8.1K bytes - Click Count (0) -
guava/src/com/google/common/collect/ImmutableList.java
* we're copying into a `contents` array whose type allows it to contain nulls. Still, it's * worth noting that we promise not to put nulls into the array in the first `size` elements. * We uphold that promise here because our callers promise that `elements` will not contain * nulls in its first `n` elements. */ System.arraycopy(elements, 0, contents, size, n); size += n;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Mar 08 16:16:42 GMT 2026 - 30.6K bytes - Click Count (0) -
docs/en/docs/js/custom.js
if(!announceRight) return; const sponsorImages = document.querySelectorAll('.sponsor-image'); const imagePromises = Array.from(sponsorImages).map(img => { return new Promise((resolve, reject) => { if (img.complete && img.naturalHeight !== 0) { resolve(); } else { img.addEventListener('load', () => {
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 17:59:48 GMT 2026 - 7.7K bytes - Click Count (2) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt
weight: Int, exclusive: Boolean, ) /** * HTTP/2 only. Receive a push promise header block. * * A push promise contains all the headers that pertain to a server-initiated request, and a * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent * as a part of the response to `streamId`. *Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 19.7K bytes - Click Count (0) -
AI_POLICY.md
This policy protects our limited review budget, allowing us to invest our attention wisely. A pull request is not a finished product—it is the start of a conversation, and an implied contract: we promise to provide thoughtful feedback, and we expect the contributor to engage with us in return. ## What we expect from contributors
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Fri Mar 27 18:43:39 GMT 2026 - 3.1K bytes - Click Count (0)