Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ListenerCallQueue (0.06 sec)

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

     * #dispatch} is expected to be called concurrently, it is idempotent.
     */
    @J2ktIncompatible
    @GwtIncompatible
    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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

    import java.util.logging.Logger;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Tests for {@link ListenerCallQueue}. */
    @NullUnmarked
    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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

    import java.util.logging.Logger;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Tests for {@link ListenerCallQueue}. */
    @NullUnmarked
    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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

    @GwtIncompatible
    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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (1)
Back to top