- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 526 for proxies (0.04 sec)
-
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 Sep 19 09:08:11 UTC 2025 - Last Modified: Sat Mar 15 06:51:20 UTC 2025 - 4.8K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.14.md
* sync time. * The goal is for administrators to be able to alert on proxies that, for * whatever reason, are quite stale.
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Mon Jun 14 22:06:39 UTC 2021 - 271.5K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/ModelBuilderResult.java
Model getEffectiveModel(); /** * Gets the profiles that were active during model building. * * @return The active profiles of the model or an empty list if the model has no active profiles. */ @Nonnull List<Profile> getActivePomProfiles(); /** * Gets the external profiles that were active during model building. External profiles are those that were
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 3.3K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/ListenableFuture.java
} @JsFunction interface IThenOnRejectedCallbackFn<V extends @Nullable Object> { V onInvoke(Object p0); } } /** Subset of the elemental2 Promise API. */ @JsType(isNative = true, namespace = JsPackage.GLOBAL, name = "Promise") class Promise<T extends @Nullable Object> implements IThenable<T> { @JsFunction interface PromiseExecutorCallbackFn<T extends @Nullable Object> { @JsFunction
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 3.8K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/profiles/ProfileManager.java
* specific language governing permissions and limitations * under the License. */ package org.apache.maven.profiles; import java.util.List; import java.util.Map; import java.util.Properties; import org.apache.maven.model.Profile; import org.apache.maven.profiles.activation.ProfileActivationException; /** * ProfileManager */ @Deprecated public interface ProfileManager {
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 1.6K bytes - Viewed (0) -
cmd/bucket-listobjects-handlers.go
var nodeIndex int if subToken, nodeIndex = parseRequestToken(token); nodeIndex >= 0 { proxied, success = proxyRequestByNodeIndex(ctx, w, r, nodeIndex, returnErr) } return } func proxyRequestByNodeIndex(ctx context.Context, w http.ResponseWriter, r *http.Request, index int, returnErr bool) (proxied, success bool) { if len(globalProxyEndpoints) == 0 {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Feb 03 21:03:04 UTC 2025 - 11.5K bytes - Viewed (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)) {
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Fri Jul 04 14:00:23 UTC 2025 - 2.2K bytes - Viewed (0) -
cmd/metrics-v2.go
Value: float64(m.Proxied.GetTotal), }) ml = append(ml, MetricV2{ Description: getClusterReplProxiedHeadOperationsMD(clusterMetricNamespace), Value: float64(m.Proxied.HeadTotal), }) ml = append(ml, MetricV2{ Description: getClusterReplProxiedPutTaggingOperationsMD(clusterMetricNamespace), Value: float64(m.Proxied.PutTagTotal), })
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 133.4K bytes - Viewed (0) -
docs/es/docs/advanced/sub-applications.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 30 18:26:57 UTC 2024 - 3K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt
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 Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 8K bytes - Viewed (0)