Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 402 for callBack (0.04 sec)

  1. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java

         * Uses OpenSearch scroll API for efficient iteration over large result sets.
         *
         * @param sessionId The session ID.
         * @param callback The callback to execute for each access result.
         */
        @Override
        public void iterate(final String sessionId, final AccessResultCallback<OpenSearchAccessResult> callback) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/ds/AbstractDataStore.java

        /**
         * Store the data.
         * @param dataConfig The data configuration.
         * @param callback The callback.
         * @param paramMap The parameters.
         * @param scriptMap The script map.
         * @param defaultDataMap The default data map.
         */
        protected abstract void storeData(DataConfig dataConfig, IndexUpdateCallback callback, DataStoreParams paramMap,
                Map<String, String> scriptMap, Map<String, Object> defaultDataMap);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/DispatcherCleanupTest.kt

    import org.junit.jupiter.api.Test
    
    class DispatcherCleanupTest {
      @StartStop
      private val server = MockWebServer()
    
      @Test
      fun testFinish() {
        val okhttp = OkHttpClient()
        val callback =
          object : Callback {
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {}
    
            override fun onResponse(
              call: Call,
              response: Response,
            ) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  4. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt

      private val source: BufferedSource,
      private val callback: Callback,
    ) {
      private var lastId: String? = null
    
      interface Callback {
        fun onEvent(
          id: String?,
          type: String?,
          data: String,
        )
    
        fun onRetryChange(timeMs: Long)
      }
    
      /**
       * Process the next event. This will result in a single call to [Callback.onEvent] *unless* the
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:47:47 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

       * java.util.concurrent.CompletableFuture#thenAcceptAsync}.
       *
       * @param callback The callback to invoke when this {@code Future} is completed.
       * @param executor The executor to run {@code callback} when the future completes.
       */
      public final void addCallback(FutureCallback<? super V> callback, Executor executor) {
        Futures.addCallback(this, callback, executor);
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/ldap/LdapUserTest.java

                    // Verify parameters
                    assertSame(ldapUser, user);
                    assertEquals("dc=example,dc=com", baseDn);
                    assertEquals("(uid=%s)", accountFilter);
                    assertEquals("(memberOf=%s)", groupFilter);
    
                    // Test callback
                    String[] callbackRoles = new String[] { "role1", "role2" };
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 16.6K bytes
    - Viewed (0)
  7. 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(
          ListenableFuture<V> future, FutureCallback<? super V> callback, Executor executor) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/util/JobProcess.java

         * Uses the default buffer size and no output callback.
         *
         * @param process the system process to wrap
         */
        public JobProcess(final Process process) {
            this(process, InputStreamThread.MAX_BUFFER_SIZE, null);
        }
    
        /**
         * Constructs a new JobProcess with the specified process, buffer size, and output callback.
         *
         * @param process the system process to wrap
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/util/SearchEngineUtil.java

         *
         * @param index the name of the index to scroll through
         * @param callback the function to apply to each search hit, returning true to continue or false to stop
         * @return the number of documents processed
         */
        public static long scroll(final String index, final Function<SearchHit, Boolean> callback) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 5.1K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/ds/DataStore.java

    package org.codelibs.fess.ds;
    
    import org.codelibs.fess.ds.callback.IndexUpdateCallback;
    import org.codelibs.fess.entity.DataStoreParams;
    import org.codelibs.fess.opensearch.config.exentity.DataConfig;
    
    /**
     * The interface for DataStore.
     */
    public interface DataStore {
    
        /**
         * Store the data.
         * @param config The data configuration.
         * @param callback The callback.
         * @param initParamMap The initial parameters.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 1.2K bytes
    - Viewed (0)
Back to top