Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 27 for Promise (0.06 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top