Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for ListenerCallQueue (0.07 sec)

  1. guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    final class ListenerCallQueue<L> {
      // TODO(cpovirk): consider using the logger associated with listener.getClass().
      private static final LazyLogger logger = new LazyLogger(ListenerCallQueue.class);
    
      // TODO(chrisn): promote AppendOnlyCollection for use here.
      private final List<PerListenerQueue<L>> listeners =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Dec 13 19:45:20 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractService.java

            }
          };
      private static final ListenerCallQueue.Event<Listener> STOPPING_FROM_STARTING_EVENT =
          stoppingEvent(STARTING);
      private static final ListenerCallQueue.Event<Listener> STOPPING_FROM_RUNNING_EVENT =
          stoppingEvent(RUNNING);
    
      private static final ListenerCallQueue.Event<Listener> TERMINATED_FROM_NEW_EVENT =
          terminatedEvent(NEW);
      private static final ListenerCallQueue.Event<Listener> TERMINATED_FROM_STARTING_EVENT =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

    import java.util.logging.Level;
    import java.util.logging.Logger;
    import junit.framework.TestCase;
    
    /** Tests for {@link ListenerCallQueue}. */
    public class ListenerCallQueueTest extends TestCase {
    
      private static final ListenerCallQueue.Event<Object> THROWING_EVENT =
          new ListenerCallQueue.Event<Object>() {
            @Override
            public void call(Object object) {
              throw new RuntimeException();
            }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

    import java.util.logging.Level;
    import java.util.logging.Logger;
    import junit.framework.TestCase;
    
    /** Tests for {@link ListenerCallQueue}. */
    public class ListenerCallQueueTest extends TestCase {
    
      private static final ListenerCallQueue.Event<Object> THROWING_EVENT =
          new ListenerCallQueue.Event<Object>() {
            @Override
            public void call(Object object) {
              throw new RuntimeException();
            }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractService.java

            }
          };
      private static final ListenerCallQueue.Event<Listener> STOPPING_FROM_STARTING_EVENT =
          stoppingEvent(STARTING);
      private static final ListenerCallQueue.Event<Listener> STOPPING_FROM_RUNNING_EVENT =
          stoppingEvent(RUNNING);
    
      private static final ListenerCallQueue.Event<Listener> TERMINATED_FROM_NEW_EVENT =
          terminatedEvent(NEW);
      private static final ListenerCallQueue.Event<Listener> TERMINATED_FROM_STARTING_EVENT =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

    @ElementTypesAreNonnullByDefault
    public final class ServiceManager implements ServiceManagerBridge {
      private static final LazyLogger logger = new LazyLogger(ServiceManager.class);
      private static final ListenerCallQueue.Event<Listener> HEALTHY_EVENT =
          new ListenerCallQueue.Event<Listener>() {
            @Override
            public void call(Listener listener) {
              listener.healthy();
            }
    
            @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/ServiceManager.java

    @ElementTypesAreNonnullByDefault
    public final class ServiceManager implements ServiceManagerBridge {
      private static final LazyLogger logger = new LazyLogger(ServiceManager.class);
      private static final ListenerCallQueue.Event<Listener> HEALTHY_EVENT =
          new ListenerCallQueue.Event<Listener>() {
            @Override
            public void call(Listener listener) {
              listener.healthy();
            }
    
            @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
Back to top