Callbacks - Code Search

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: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 50.7K bytes

- Viewed (0)

github.com/codelibs/fess

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: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 49K bytes

- Viewed (0)

github.com/codelibs/fess

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: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 51.1K bytes

- Viewed (0)

github.com/codelibs/fess

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: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 57.4K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/FallbackTestClientSocketFactory.kt

        }
      }
      delegate!!.enabledCipherSuites = enabledCipherSuites.toTypedArray<String>()
    }
  }

  companion object {
    /**
     * The cipher suite used during TLS connection fallback to indicate a fallback. See
     * https://tools.ietf.org/html/draft-ietf-tls-downgrade-scsv-00
     */
    const val TLS_FALLBACK_SCSV = "TLS_FALLBACK_SCSV"
  }

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Mon Jan 08 01:13:22 UTC 2024

- 2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/es/log/cbean/ca/bs/BsFavoriteLogCA.java

        if (queryLambda != null) {
            queryLambda.callback(cq);
        }
        FilterAggregationBuilder builder = regFilterA(name, cq.getQuery());
        if (opLambda != null) {
            opLambda.callback(builder);
        }
        if (aggsLambda != null) {
            FavoriteLogCA ca = new FavoriteLogCA();
            aggsLambda.callback(ca);

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 28.1K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt

    data.write("8a00".decodeHex()) // Pong
    data.write("80026c6f".decodeHex()) // lo
    clientReader.processNextFrame()
    callback.assertPong(EMPTY)
    callback.assertPong(EMPTY)
    callback.assertPong(EMPTY)
    callback.assertPong(EMPTY)
    callback.assertTextMessage("Hello")
  }

  @Test fun clientTwoFrameCompressedHelloWithPongs() {

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Mon Jan 08 01:13:22 UTC 2024

- 14.4K bytes

- Viewed (1)

github.com/codelibs/fess-suggest

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

            Consumer<RESPONSE> callback;
            while ((callback = doneCallbacks.poll()) != null) {
                executeCallbacks.add(callback);
            }
        }
        if (executeCallbacks.size() > 0) {
            try {
                executeCallbacks.stream().forEach(callback -> callback.accept(response));
            } catch (final Exception ignore) {}
        }

Registered: Fri Nov 08 09:08:12 UTC 2024

- Last Modified: Thu Feb 22 01:36:54 UTC 2024

- 5.4K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/es/config/cbean/cq/bs/BsCrawlingInfoCQ.java

        CrawlingInfoCQ cq = new CrawlingInfoCQ();
        queryLambda.callback(cq);
        final Collection<FilterFunctionBuilder> list = new ArrayList<>();
        if (functionsLambda != null) {
            functionsLambda.callback((cqLambda, scoreFunctionBuilder) -> {
                CrawlingInfoCQ cf = new CrawlingInfoCQ();
                cqLambda.callback(cf);

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 34.5K bytes

- Viewed (0)

github.com/golang/go

lib/wasm/wasm_exec.js

			fchown(fd, uid, gid, callback) { callback(enosys()); },
			fstat(fd, callback) { callback(enosys()); },
			fsync(fd, callback) { callback(null); },
			ftruncate(fd, length, callback) { callback(enosys()); },
			lchown(path, uid, gid, callback) { callback(enosys()); },
			link(path, link, callback) { callback(enosys()); },
			lstat(path, callback) { callback(enosys()); },
			mkdir(path, perm, callback) { callback(enosys()); },

Registered: Tue Nov 05 11:13:11 UTC 2024

- Last Modified: Fri Aug 30 19:15:21 UTC 2024

- 16.5K bytes

- Viewed (0)

Search Options