- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 78 for __callback (0.16 sec)
-
src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsDuplicateHostCA.java
if (queryLambda != null) { queryLambda.callback(cq); } FilterAggregationBuilder builder = regFilterA(name, cq.getQuery()); if (opLambda != null) { opLambda.callback(builder); } if (aggsLambda != null) { DuplicateHostCA ca = new DuplicateHostCA(); aggsLambda.callback(ca);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 50.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsRoleTypeCA.java
if (queryLambda != null) { queryLambda.callback(cq); } FilterAggregationBuilder builder = regFilterA(name, cq.getQuery()); if (opLambda != null) { opLambda.callback(builder); } if (aggsLambda != null) { RoleTypeCA ca = new RoleTypeCA(); aggsLambda.callback(ca); ca.getAggregationBuilderList().forEach(builder::subAggregation);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 49K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/cbean/cq/bs/BsThumbnailQueueCQ.java
ThumbnailQueueCQ cq = new ThumbnailQueueCQ(); queryLambda.callback(cq); final Collection<FilterFunctionBuilder> list = new ArrayList<>(); if (functionsLambda != null) { functionsLambda.callback((cqLambda, scoreFunctionBuilder) -> { ThumbnailQueueCQ cf = new ThumbnailQueueCQ(); cqLambda.callback(cf);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 51.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/cbean/cq/bs/BsFailureUrlCQ.java
FailureUrlCQ cq = new FailureUrlCQ(); queryLambda.callback(cq); final Collection<FilterFunctionBuilder> list = new ArrayList<>(); if (functionsLambda != null) { functionsLambda.callback((cqLambda, scoreFunctionBuilder) -> { FailureUrlCQ cf = new FailureUrlCQ(); cqLambda.callback(cf);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 57.4K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
} func setup(t *testing.T, devs []*pluginapi.Device, callback monitorCallback, socketName string, pluginSocketName string) (Manager, <-chan interface{}, *plugin.Stub) { m, updateChan := setupDeviceManager(t, devs, callback, socketName, nil) p := setupDevicePlugin(t, devs, pluginSocketName) return m, updateChan, p }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* * @param future The future attach the callback to. * @param callback The callback to invoke when {@code future} is completed. * @param executor The executor to run {@code callback} when the future completes. * @since 10.0 */ public static <V extends @Nullable Object> void addCallback( final ListenableFuture<V> future, final FutureCallback<? super V> callback, Executor executor) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 59.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
* * @param future The future attach the callback to. * @param callback The callback to invoke when {@code future} is completed. * @param executor The executor to run {@code callback} when the future completes. * @since 10.0 */ public static <V extends @Nullable Object> void addCallback( final ListenableFuture<V> future, final FutureCallback<? super V> callback, Executor executor) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 64.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
} response.request } val blockingAuthClient = client.newBuilder() .authenticator(authenticator) .build() val callback: Callback = object : Callback { override fun onFailure( call: Call, e: IOException, ) { fail("") } override fun onResponse(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
src/crypto/tls/handshake_client_test.go
return errors.New("callback err") }, // testHandshake returns the server side error, so we just need to // check alertBadCertificate was sent expectedErr: "callback err", }, { name: "VerifyConnection, err", verifyConnection: func(ConnectionState) error { return errors.New("callback err") }, expectedErr: "tls: server rejected ECH",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 88.7K bytes - Viewed (0) -
src/crypto/tls/common.go
// considering this callback. If normal verification is disabled (on the // client when InsecureSkipVerify is set, or on a server when ClientAuth is // RequestClientCert or RequireAnyClientCert), then this callback will be // considered but the verifiedChains argument will always be nil. When // ClientAuth is NoClientCert, this callback is not called on the server.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 59.1K bytes - Viewed (0)