Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 138 for eventbus (0.05 sec)

  1. guava-tests/benchmark/com/google/common/eventbus/EventBusBenchmark.java

     */
    
    package com.google.common.eventbus;
    
    import com.google.caliper.BeforeExperiment;
    import com.google.caliper.Benchmark;
    
    /**
     * Benchmark for {@link EventBus}.
     *
     * @author Eric Fellheimer
     */
    public class EventBusBenchmark {
    
      private EventBus eventBus;
    
      @BeforeExperiment
      void setUp() {
        eventBus = new EventBus("for benchmarking purposes");
        eventBus.register(this);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 1.2K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/eventbus/outside/AbstractEventBusTest.java

     * limitations under the License.
     */
    
    package com.google.common.eventbus.outside;
    
    import com.google.common.eventbus.EventBus;
    import junit.framework.TestCase;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Abstract base class for tests that EventBus finds the correct subscribers.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 17 15:19:38 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/eventbus/package-info.java

    /**
     * <a href="https://guava.dev/EventBus">Discouraged</a> 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
    @ParametersAreNonnullByDefault
    package com.google.common.eventbus;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 23 19:57:03 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/eventbus/AsyncEventBus.java

     * the License.
     */
    
    package com.google.common.eventbus;
    
    import java.util.concurrent.Executor;
    
    /**
     * An {@link EventBus} that takes the Executor of your choice and uses it to dispatch events,
     * allowing dispatch to occur asynchronously.
     *
     * @author Cliff Biffle
     * @since 10.0
     */
    @ElementTypesAreNonnullByDefault
    public class AsyncEventBus extends EventBus {
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Apr 22 13:05:46 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/eventbus/PackageSanityTests.java

        private final EventBus eventBus = new EventBus();
    
        @Subscribe
        public void handle(@Nullable Object unused) {}
    
        Subscriber toSubscriber() throws Exception {
          return Subscriber.create(eventBus, this, subscriberMethod());
        }
    
        SubscriberExceptionContext toContext() {
          return new SubscriberExceptionContext(eventBus, new Object(), this, subscriberMethod());
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/eventbus/Subscriber.java

      static Subscriber create(EventBus bus, Object listener, Method method) {
        return isDeclaredThreadSafe(method)
            ? new Subscriber(bus, listener, method)
            : new SynchronizedSubscriber(bus, listener, method);
      }
    
      /** The event bus this subscriber belongs to. */
      @Weak private EventBus bus;
    
      /** The object with the subscriber method. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 06 00:47:57 UTC 2021
    - 4.7K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/eventbus/SubscriberExceptionContext.java

        this.eventBus = checkNotNull(eventBus);
        this.event = checkNotNull(event);
        this.subscriber = checkNotNull(subscriber);
        this.subscriberMethod = checkNotNull(subscriberMethod);
      }
    
      /**
       * @return The {@link EventBus} that handled the event and the subscriber. Useful for broadcasting
       *     a new event based on the error.
       */
      public EventBus getEventBus() {
        return eventBus;
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Apr 22 13:05:46 UTC 2021
    - 2.2K bytes
    - Viewed (0)
  8. guava/src/com/google/common/eventbus/package-info.java

    /**
     * <a href="https://guava.dev/EventBus">Discouraged</a> 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
    @ParametersAreNonnullByDefault
    package com.google.common.eventbus;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 23 19:57:03 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/eventbus/outside/OutsideEventBusTest.java

     * limitations under the License.
     */
    
    package com.google.common.eventbus.outside;
    
    import com.google.common.eventbus.EventBus;
    import com.google.common.eventbus.Subscribe;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicReference;
    import junit.framework.TestCase;
    
    /**
     * Test cases for {@code EventBus} that must not be in the same package.
     *
     * @author Louis Wasserman
     */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 1.8K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/eventbus/outside/AbstractEventBusTest.java

     * limitations under the License.
     */
    
    package com.google.common.eventbus.outside;
    
    import com.google.common.eventbus.EventBus;
    import junit.framework.TestCase;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Abstract base class for tests that EventBus finds the correct subscribers.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 17 15:19:38 UTC 2023
    - 1.6K bytes
    - Viewed (0)
Back to top