Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for testPerThreadQueuedDispatcher (0.12 sec)

  1. android/guava-tests/test/com/google/common/eventbus/DispatcherTest.java

      private final ConcurrentLinkedQueue<Object> dispatchedSubscribers =
          Queues.newConcurrentLinkedQueue();
    
      private Dispatcher dispatcher;
    
      public void testPerThreadQueuedDispatcher() {
        dispatcher = Dispatcher.perThreadDispatchQueue();
        dispatcher.dispatch(1, integerSubscribers.iterator());
    
        assertThat(dispatchedSubscribers)
            .containsExactly(
                i1,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 27 15:41:25 UTC 2022
    - 5.6K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/eventbus/DispatcherTest.java

      private final ConcurrentLinkedQueue<Object> dispatchedSubscribers =
          Queues.newConcurrentLinkedQueue();
    
      private Dispatcher dispatcher;
    
      public void testPerThreadQueuedDispatcher() {
        dispatcher = Dispatcher.perThreadDispatchQueue();
        dispatcher.dispatch(1, integerSubscribers.iterator());
    
        assertThat(dispatchedSubscribers)
            .containsExactly(
                i1,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 27 15:41:25 UTC 2022
    - 5.6K bytes
    - Viewed (0)
Back to top