__callback - Code Search

src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsThumbnailQueueCA.java

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

Registered: Wed Jun 12 13:08:18 UTC 2024

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

- 38.6K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/es/user/cbean/cq/bs/BsGroupCQ.java

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

Registered: Wed Jun 12 13:08:18 UTC 2024

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

- 20K bytes

- Viewed (0)

github.com/square/okhttp

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

    dispatcher.maxRequests = 2
    client.newCall(newRequest("http://a/1")).enqueue(callback)
    client.newCall(newRequest("http://b/1")).enqueue(callback)
    client.newCall(newRequest("http://c/1")).enqueue(callback)
    client.newCall(newRequest("http://a/2")).enqueue(callback)
    client.newCall(newRequest("http://b/2")).enqueue(callback)
    dispatcher.maxRequests = 4

Registered: Sun Jun 16 04:42:17 UTC 2024

- Last Modified: Fri Apr 05 03:30:42 UTC 2024

- 12.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsBadWordCA.java

        if (queryLambda != null) {
            queryLambda.callback(cq);
        }
        FilterAggregationBuilder builder = regFilterA(name, cq.getQuery());
        if (opLambda != null) {
            opLambda.callback(builder);
        }
        if (aggsLambda != null) {
            BadWordCA ca = new BadWordCA();
            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

- 46.6K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/es/user/cbean/cq/bs/BsRoleCQ.java

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

Registered: Wed Jun 12 13:08:18 UTC 2024

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

- 13.9K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsCrawlingInfoCA.java

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

Registered: Wed Jun 12 13:08:18 UTC 2024

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

- 31.5K bytes

- Viewed (0)

github.com/golang/go

src/runtime/cgocall.go

	gp.m.incgo = false
	if gp.m.isextra {
		gp.m.isExtraInC = false
	}

	osPreemptExtExit(gp.m)

	if gp.nocgocallback {
		panic("runtime: function marked with #cgo nocallback called back into Go")
	}

	cgocallbackg1(fn, frame, ctxt)

	// At this point we're about to call unlockOSThread.
	// The following code must not change to a different m.

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Thu May 23 01:16:47 UTC 2024

- 24.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsCrawlingInfoParamCA.java

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

Registered: Wed Jun 12 13:08:18 UTC 2024

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

- 28.8K 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: Sun Jun 16 04:42:17 UTC 2024

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

- 14.4K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/es/user/cbean/ca/bs/BsGroupCA.java

        if (queryLambda != null) {
            queryLambda.callback(cq);
        }
        FilterAggregationBuilder builder = regFilterA(name, cq.getQuery());
        if (opLambda != null) {
            opLambda.callback(builder);
        }
        if (aggsLambda != null) {
            GroupCA ca = new GroupCA();
            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

- 17.7K bytes

- Viewed (0)

Search Options