Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 26 for Promise (0.23 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/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)
  4. 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)
  5. 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)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt

            flags = FLAG_ACK,
          )
          sink.flush()
        }
      }
    
      /**
       * HTTP/2 only. Send 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`. The `promisedStreamId` has a priority of one greater than
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 11K bytes
    - Click Count (0)
  7. 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)
  8. android/guava/src/com/google/common/collect/ImmutableCollection.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: Thu Jan 29 22:14:05 GMT 2026
    - 21.4K bytes
    - Click Count (0)
  9. mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt

        /**
         * When [protocols][MockWebServer.protocols] include [HTTP_2][okhttp3.Protocol], this attaches a
         * pushed stream to this response.
         */
        public fun addPush(promise: PushPromise): Builder =
          apply {
            this.pushPromises_ += promise
          }
    
        /**
         * When [protocols][MockWebServer.protocols] include [HTTP_2][okhttp3.Protocol], this pushes
         * [settings] before writing the response.
         */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 17.8K bytes
    - Click Count (0)
  10. src/main/webapp/js/popper.min.js

    ar o=f.orderedModifiers[r],i=o.fn,a=o.options,s=void 0===a?{}:a,c=o.name;"function"==typeof i&&(f=i({state:f,options:s,name:c,instance:u})||f)}else f.reset=!1,r=-1}}},update:(i=function(){return new Promise((function(e){u.forceUpdate(),e(f)}))},function(){return s||(s=new Promise((function(e){Promise.resolve().then((function(){s=void 0,e(i())}))}))),s}),destroy:function(){l(),p=!0}};if(!Q(e,t))return u;function l(){c.forEach((function(e){return e()})),c=[]}return u.setOptions(r).then((function(e...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 12 06:14:02 GMT 2025
    - 19.7K bytes
    - Click Count (0)
Back to Top