Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for perThreadDispatchQueue (0.24 sec)

  1. android/guava/src/com/google/common/eventbus/Dispatcher.java

       * thread. That is, all subscribers to a single event A will be called before any subscribers to
       * any events B and C that are posted to the event bus by the subscribers to A.
       */
      static Dispatcher perThreadDispatchQueue() {
        return new PerThreadQueuedDispatcher();
      }
    
      /**
       * Returns a dispatcher that queues events that are posted in a single global queue. This behavior
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Dec 15 19:31:54 GMT 2023
    - 7.3K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/eventbus/DispatcherTest.java

          Queues.newConcurrentLinkedQueue();
    
      private Dispatcher dispatcher;
    
      public void testPerThreadQueuedDispatcher() {
        dispatcher = Dispatcher.perThreadDispatchQueue();
        dispatcher.dispatch(1, integerSubscribers.iterator());
    
        assertThat(dispatchedSubscribers)
            .containsExactly(
                i1,
                i2,
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Apr 27 15:41:25 GMT 2022
    - 5.6K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/eventbus/DispatcherTest.java

          Queues.newConcurrentLinkedQueue();
    
      private Dispatcher dispatcher;
    
      public void testPerThreadQueuedDispatcher() {
        dispatcher = Dispatcher.perThreadDispatchQueue();
        dispatcher.dispatch(1, integerSubscribers.iterator());
    
        assertThat(dispatchedSubscribers)
            .containsExactly(
                i1,
                i2,
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 27 15:41:25 GMT 2022
    - 5.6K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/eventbus/EventBus.java

       *     identifier.
       */
      public EventBus(String identifier) {
        this(
            identifier,
            MoreExecutors.directExecutor(),
            Dispatcher.perThreadDispatchQueue(),
            LoggingHandler.INSTANCE);
      }
    
      /**
       * Creates a new EventBus with the given {@link SubscriberExceptionHandler}.
       *
       * @param exceptionHandler Handler for subscriber exceptions.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Aug 25 16:37:57 GMT 2021
    - 12.8K bytes
    - Viewed (0)
Back to top