Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 299 for callback2 (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  2. github.com/codelibs/fess

    src/main/java/org/codelibs/fess/opensearch/config/cbean/cq/bs/BsWebConfigCQ.java 

            WebConfigCQ cq = new WebConfigCQ();
        queryLambda.callback(cq);
        final Collection<FilterFunctionBuilder> list = new ArrayList<>();
        if (functionsLambda != null) {
            functionsLambda.callback((cqLambda, scoreFunctionBuilder) -> {
                WebConfigCQ cf = new WebConfigCQ();
                cqLambda.callback(cf);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 172.1K bytes
    - Click Count (0)
  3. github.com/google/guava

    android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java 

            output.cancel(false);
        throw new SomeUncheckedException();
      }
    }
    Fallback fallback = new Fallback();
    SettableFuture<Object> input = SettableFuture.create();

    ListenableFuture<Object> output = catching(input, Throwable.class, fallback, directExecutor());
    fallback.output = output;

    input.setException(new MyException());
    assertTrue(output.isCancelled());
  }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  4. github.com/google/guava

    guava-tests/test/com/google/common/util/concurrent/FuturesTest.java 

            output.cancel(false);
        throw new SomeUncheckedException();
      }
    }
    Fallback fallback = new Fallback();
    SettableFuture<Object> input = SettableFuture.create();

    ListenableFuture<Object> output = catching(input, Throwable.class, fallback, directExecutor());
    fallback.output = output;

    input.setException(new MyException());
    assertTrue(output.isCancelled());
  }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  5. github.com/codelibs/fess

    src/main/java/org/codelibs/fess/opensearch/log/cbean/cq/bs/BsSearchLogCQ.java 

            SearchLogCQ cq = new SearchLogCQ();
        queryLambda.callback(cq);
        final Collection<FilterFunctionBuilder> list = new ArrayList<>();
        if (functionsLambda != null) {
            functionsLambda.callback((cqLambda, scoreFunctionBuilder) -> {
                SearchLogCQ cf = new SearchLogCQ();
                cqLambda.callback(cf);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 145.5K bytes
    - Click Count (0)
  6. github.com/codelibs/fess

    src/test/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImplTest.java 

                    return 0;
            }

            @Override
            public void commit() {
            }
        };

        FileListIndexUpdateCallbackImpl callback = new FileListIndexUpdateCallbackImpl(mockCallback, null, 1);
        callback.setMaxDeleteDocumentCacheSize(1000);

        final int threadCount = 10;
        final int urlsPerThread = 100;
        final Thread[] threads = new Thread[threadCount];
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 19.7K bytes
    - Click Count (0)
  7. github.com/codelibs/fess

    src/main/java/org/codelibs/fess/opensearch/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);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 17.7K bytes
    - Click Count (0)
  8. github.com/square/okhttp

    okhttp/src/jvmTest/kotlin/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)

    val dispatcherQueueStartC1 = eventRecorder.removeUpToEvent<DispatcherQueueStart>()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  9. github.com/codelibs/fess

    src/main/java/org/codelibs/fess/opensearch/config/cbean/cq/bs/BsLabelTypeCQ.java 

            LabelTypeCQ cq = new LabelTypeCQ();
        queryLambda.callback(cq);
        final Collection<FilterFunctionBuilder> list = new ArrayList<>();
        if (functionsLambda != null) {
            functionsLambda.callback((cqLambda, scoreFunctionBuilder) -> {
                LabelTypeCQ cf = new LabelTypeCQ();
                cqLambda.callback(cf);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 87.8K bytes
    - Click Count (0)
  10. github.com/codelibs/fess

    src/main/java/org/codelibs/fess/opensearch/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);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 46.6K bytes
    - Click Count (0)
  11. github.com/codelibs/fess

    src/test/java/org/codelibs/fess/chat/ChatPhaseCallbackTest.java 

                }
        };

        // Simulate typical flow
        callback.onPhaseStart(ChatPhaseCallback.PHASE_INTENT, "msg");
        callback.onPhaseStart(ChatPhaseCallback.PHASE_SEARCH, "msg");
        callback.onPhaseStart(ChatPhaseCallback.PHASE_EVALUATE, "msg");
        callback.onPhaseStart(ChatPhaseCallback.PHASE_FETCH, "msg");
        callback.onPhaseStart(ChatPhaseCallback.PHASE_ANSWER, "msg");
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Jan 12 10:32:40 GMT 2026
    - 7.3K bytes
    - Click Count (0)
Back to Top