Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for subscriber (0.16 sec)

  1. guava-tests/test/com/google/common/eventbus/outside/AbstractNotAnnotatedInSuperclassTest.java

     * limitations under the License.
     */
    
    package com.google.common.eventbus.outside;
    
    import static com.google.common.truth.Truth.assertThat;
    
    import com.google.common.eventbus.Subscribe;
    import com.google.common.eventbus.outside.AbstractNotAnnotatedInSuperclassTest.SubClass;
    import java.util.ArrayList;
    import java.util.List;
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/eventbus/AsyncEventBus.java

       *     down the executor after the last event has been posted to this event bus.
       * @param subscriberExceptionHandler Handler used to handle exceptions thrown from subscribers.
       *     See {@link SubscriberExceptionHandler} for more information.
       * @since 16.0
       */
      public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  3. guava/src/com/google/common/eventbus/package-info.java

     * the License.
     */
    
    /**
     * {@linkplain EventBus Discouraged} in favor of dependency injection and concurrency frameworks,
     * EventBus allows publish-subscribe-style communication.
     *
     * <p>See the Guava User Guide article on <a
     * href="https://github.com/google/guava/wiki/EventBusExplained">{@code EventBus}</a>.
     */
    @CheckReturnValue
    @NullMarked
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jan 03 19:02:39 UTC 2025
    - 1K bytes
    - Viewed (0)
  4. guava-tests/benchmark/com/google/common/eventbus/EventBusBenchmark.java

        eventBus.register(this);
      }
    
      @Benchmark
      void postStrings(int reps) {
        for (int i = 0; i < reps; i++) {
          eventBus.post("hello there");
        }
      }
    
      @Subscribe
      public void handleStrings(String string) {
        // Nothing to do here.
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  5. CHANGELOG/CHANGELOG-1.29.md

    - `EnqueueExtensions` from plugins other than `PreEnqueue`, `PreFilter`, `Filter`, `Reserve` and `Permit` are now ignored.
      It reduces the number of kinds of cluster events the scheduler needs to subscribe/handle. ([#121571](https://github.com/kubernetes/kubernetes/pull/121571), [@sanposhiho](https://github.com/sanposhiho))
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Wed Mar 12 00:36:01 UTC 2025
    - 429.6K bytes
    - Viewed (1)
  6. CHANGELOG/CHANGELOG-1.32.md

    - When `SchedulerQueueingHint` is enabled,
      the scheduler's in-tree plugins now subscribe to specific node events to decide whether to requeue Pods.
      This allows the scheduler to handle cluster events faster with less memory.
    
      Specific node events include updates to taints, tolerations or allocatable.
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Tue Dec 16 18:27:41 UTC 2025
    - 448.1K bytes
    - Viewed (0)
Back to top