Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 62 for eventbus (0.04 sec)

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

      private final Dispatcher dispatcher;
    
      /** Creates a new EventBus named "default". */
      public EventBus() {
        this("default");
      }
    
      /**
       * Creates a new EventBus with the given {@code identifier}.
       *
       * @param identifier a brief name for this bus, for logging purposes. Should be a valid Java
       *     identifier.
       */
      public EventBus(String identifier) {
        this(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/eventbus/EventBusTest.java

              catcher.getEvents());
        }
      }
    
      public void testToString() throws Exception {
        EventBus eventBus = new EventBus("a b ; - \" < > / \\ €");
        assertEquals("EventBus{a b ; - \" < > / \\ €}", eventBus.toString());
      }
    
      /**
       * Tests that bridge methods are not subscribed to events. In Java 8, annotations are included on
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/eventbus/SubscriberRegistry.java

       */
      private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers =
          Maps.newConcurrentMap();
    
      /** The event bus this registry belongs to. */
      @Weak private final EventBus bus;
    
      SubscriberRegistry(EventBus bus) {
        this.bus = checkNotNull(bus);
      }
    
      /** Registers all subscriber methods on the given listener object. */
      void register(Object listener) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Jul 08 18:32:10 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

     * request body start and end events occur within the response header events. Similarly,
     * [duplex calls][RequestBody.isDuplex] interleave the request and response bodies.
     *
     * Since connections may be reused, the proxy selection, DNS, and connect events may not be present
     * for a call. In future releases of OkHttp these events may also occur concurrently to permit
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/pool/CrawlerPooledObjectFactoryTest.java

            assertEquals(1, events.size());
            assertEquals("listener1", events.get(0));
    
            // Switch to listener2
            factory.setOnDestroyListener(listener2);
            assertEquals(listener2, factory.getOnDestroyListener());
            factory.destroyObject(pooledObject);
            assertEquals(2, events.size());
            assertEquals("listener2", events.get(1));
    
            // Clear listener
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Wed Sep 03 14:42:53 UTC 2025
    - 19.3K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt

        cancelLatch.await()
    
        val events = listener.eventSequence.filter { isConnectionEvent(it) }.map { it.name }
        listener.clearAllEvents()
    
        assertThat(events).startsWith("CallStart", "ConnectStart", "ConnectEnd", "ConnectionAcquired")
        if (cancelMode == CANCEL) {
          assertThat(events).contains("Canceled")
        } else {
          assertThat(events).doesNotContain("Canceled")
        }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/impl/LogHelperImpl.java

    import org.codelibs.fess.crawler.log.LogType;
    
    /**
     * Implementation of the {@link LogHelper} interface.
     * This class provides methods for logging various events during the crawling process.
     * It uses Log4j2 for logging.
     *
     * <p>
     * The class contains methods for logging different types of events, such as:
     * </p>
     * <ul>
     *   <li>Starting and finishing threads</li>
     *   <li>Starting and cleaning up crawling</li>
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        return NANOSECONDS.toMillis(stopwatch.instant - startTime);
      }
    
      private void assertEvents(String... events) {
        assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear());
      }
    
      /**
       * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds
       * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        return NANOSECONDS.toMillis(stopwatch.instant - startTime);
      }
    
      private void assertEvents(String... events) {
        assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear());
      }
    
      /**
       * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds
       * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  10. compat/maven-compat/src/test/java/org/apache/maven/repository/legacy/DefaultWagonManagerTest.java

    import org.apache.maven.wagon.TransferFailedException;
    import org.apache.maven.wagon.UnsupportedProtocolException;
    import org.apache.maven.wagon.Wagon;
    import org.apache.maven.wagon.events.TransferEvent;
    import org.apache.maven.wagon.events.TransferListener;
    import org.apache.maven.wagon.observers.AbstractTransferListener;
    import org.apache.maven.wagon.observers.Debug;
    import org.codehaus.plexus.testing.PlexusTest;
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 12.9K bytes
    - Viewed (0)
Back to top