Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 763 for promise (0.05 sec)

  1. src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java

            latch.countDown();
        }
    
        public Promise then(final Consumer<RESPONSE> consumer) {
            return promise.then(consumer);
        }
    
        public Promise error(final Consumer<Throwable> consumer) {
            return promise.error(consumer);
        }
    
        public Promise promise() {
            return promise;
        }
    
        public class Promise {
            public Promise then(final Consumer<RESPONSE> consumer) {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java

                deferred.resolve(new SuggestResponse("", 0, Collections.emptyList(), 0, null));
            });
            th.start();
    
            final CountDownLatch latch = new CountDownLatch(1);
            deferred.promise().then(response -> latch.countDown());
            assertTrue(latch.await(10, TimeUnit.SECONDS));
        }
    
        @Test
        public void test_doneAfterResolve() throws Exception {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/suggest/request/Request.java

    import org.codelibs.fess.suggest.exception.SuggesterException;
    import org.opensearch.client.Client;
    import org.opensearch.core.common.Strings;
    
    public abstract class Request<T extends Response> {
        public Deferred<T>.Promise execute(final Client client) {
            final String error = getValidationError();
            if (!Strings.isNullOrEmpty(error)) {
                throw new IllegalArgumentException(error);
            }
    
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/SocketChannelTest.kt

        val request =
          Request.Builder()
            .url(url)
            .build()
    
        val promise = CompletableFuture<Response>()
    
        val call = client.newCall(request)
        call.enqueue(
          object : Callback {
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
              promise.completeExceptionally(e)
            }
    
            override fun onResponse(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 8K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

            }
        }
    
        @Deprecated
        public Deferred<SuggestIndexResponse>.Promise indexFromDocument(final Supplier<DocumentReader> reader, final int docPerReq,
                final long requestInterval) {
            return indexFromDocument(reader, docPerReq, () -> ThreadUtil.sleep(requestInterval));
        }
    
        public Deferred<SuggestIndexResponse>.Promise indexFromDocument(final Supplier<DocumentReader> reader, final int docPerReq,
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  6. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockResponse.kt

        headersDelayAmount = delay
        headersDelayUnit = unit
      }
    
      fun getHeadersDelay(unit: TimeUnit): Long = unit.convert(headersDelayAmount, headersDelayUnit)
    
      fun withPush(promise: PushPromise) =
        apply {
          promises.add(promise)
        }
    
      fun withSettings(settings: Settings) =
        apply {
          this.settings = settings
        }
    
      fun withWebSocketUpgrade(listener: WebSocketListener) =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.2K bytes
    - Viewed (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;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 16 19:14:45 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  8. okhttp/src/main/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
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/suggest/request/RequestBuilder.java

        protected Req request;
    
        public RequestBuilder(final Client client, final Req request) {
            this.client = client;
            this.request = request;
        }
    
        public Deferred<Res>.Promise execute() {
            return request.execute(client);
        }
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  10. okhttp/src/main/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`.
         *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
Back to top