- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 62 for eventbus (0.04 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)