Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 8 of 8 for listener (0.06 seconds)

  1. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

         */
        @Override
        public void pitSegments(final PitSegmentsRequest pitSegmentsRequest, final ActionListener<IndicesSegmentResponse> listener) {
            client.pitSegments(pitSegmentsRequest, listener);
        }
    
        /**
         * Searches a view asynchronously (not implemented).
         *
         * @param request  the search view request
         * @param listener the response listener
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 14:36:23 GMT 2026
    - 138.6K bytes
    - Click Count (1)
  2. src/main/java/org/codelibs/fess/helper/SystemHelper.java

            return buf.toString();
        }
    
        /**
         * Adds a listener for configuration updates.
         *
         * @param name     The name of the listener.
         * @param listener The listener to add.
         */
        public void addUpdateConfigListener(final String name, final Supplier<String> listener) {
            updateConfigListenerMap.put(name, listener);
        }
    
        /**
         * Checks if the cluster state has changed.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 43.2K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java

        FakeTicker ticker = new FakeTicker();
        QueuingRemovalListener<Integer, Integer> listener =
            TestingRemovalListeners.queuingRemovalListener();
        Cache<Integer, Integer> cache =
            CacheBuilder.newBuilder()
                .expireAfterAccess(1, MINUTES)
                .removalListener(listener)
                .ticker(ticker)
                .build();
        cache.put(1, 1);
        ticker.advance(10, MINUTES);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 16:38:16 GMT 2026
    - 19.1K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/cache/LocalCache.java

      final long refreshNanos;
    
      /** Entries waiting to be consumed by the removal listener. */
      // TODO(fry): define a new type which creates event objects and automates the clear logic
      final Queue<RemovalNotification<K, V>> removalNotificationQueue;
    
      /**
       * A listener that is invoked when an entry is removed due to expiration or garbage collection of
       * soft/weak entries.
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 143.5K bytes
    - Click Count (0)
  5. guava/src/com/google/common/cache/LocalCache.java

      final long refreshNanos;
    
      /** Entries waiting to be consumed by the removal listener. */
      // TODO(fry): define a new type which creates event objects and automates the clear logic
      final Queue<RemovalNotification<K, V>> removalNotificationQueue;
    
      /**
       * A listener that is invoked when an entry is removed due to expiration or garbage collection of
       * soft/weak entries.
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 148.9K bytes
    - Click Count (0)
  6. guava-testlib/src/com/google/common/collect/testing/Helpers.java

        return () ->
            new Iterator<T>() {
              private final ListIterator<T> listIter = list.listIterator(list.size());
    
              @Override
              public boolean hasNext() {
                return listIter.hasPrevious();
              }
    
              @Override
              public T next() {
                return listIter.previous();
              }
    
              @Override
              public void remove() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 17.2K bytes
    - Click Count (0)
  7. build-logic/build-update-utils/src/main/kotlin/gradlebuild/buildutils/tasks/UpdateFixedIssuesInReleaseNotes.kt

                // Find the end of the issues list: the first non-list line after the intro
                val listEnd = findEndOfListSection(content, afterIntro)
                content.substring(0, introStart) + newSection + "\n" + content.substring(listEnd)
            } else {
                newSection + "\n" + content
            }
    
            notesFile.writeText(newContent)
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Mar 23 14:49:33 GMT 2026
    - 5.1K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

       *
       * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
       * the discussion in the {@link ListenableFuture#addListener} documentation. All its warnings
       * about heavyweight listeners are also applicable to heavyweight functions passed to this method.
       *
       * <p>After calling this method, you may not call {@link #finishToFuture()}, {@link
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 101.7K bytes
    - Click Count (0)
Back to Top