- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 78 for Subscriber (0.24 sec)
-
android/guava/src/com/google/common/eventbus/AsyncEventBus.java
* down the executor after the last event has been posted to this event bus. * @param subscriberExceptionHandler Handler used to handle exceptions thrown from subscribers. * See {@link SubscriberExceptionHandler} for more information. * @since 16.0 */ public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 22 13:05:46 GMT 2021 - 2.5K bytes - Viewed (0) -
.github/ISSUE_TEMPLATE/bug_report.md
--- name: Bug report about: Create a report to help us improve title: '' labels: community, triage assignees: '' --- ## NOTE If this case is urgent, please subscribe to [Subnet](https://min.io/pricing) so that our 24/7 support team may help you faster. <!--- Provide a general summary of the issue in the Title above --> ## Expected Behavior <!--- If you're describing a bug, tell us what should happen -->
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 20 17:37:40 GMT 2022 - 1.7K bytes - Viewed (0) -
maven-core/src/test/resources/projects/fully-populated-child.xml
<developerConnection>developer-connection</developerConnection> <url>repository-url</url> </scm> <mailingLists> <mailingList> <name>Maven User List</name> <subscribe>subscribe</subscribe> <unsubscribe>unsubscribe</unsubscribe> <archive>archive</archive> </mailingList> </mailingLists> <developers> <developer> <name>Jason van Zyl</name>
XML - Registered: Sun Mar 31 03:35:09 GMT 2024 - Last Modified: Wed Feb 28 22:49:30 GMT 2007 - 4.7K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/eventbus/EventBusBenchmark.java
eventBus.register(this); } @Benchmark void postStrings(int reps) { for (int i = 0; i < reps; i++) { eventBus.post("hello there"); } } @Subscribe public void handleStrings(String string) { // Nothing to do here. }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 1.2K bytes - Viewed (0) -
maven-core/src/test/resources/org/apache/maven/extension/test-extension-repo/org/apache/apache/3/apache-3.pom
</snapshotRepository> </distributionManagement> <mailingLists> <mailingList> <name>Apache Announce List</name> <subscribe>announce-subscribe@apache.org</subscribe> <unsubscribe>******@****.***</unsubscribe> <post>******@****.***</post> <archive>http://mail-archives.apache.org/mod_mbox/www-announce/</archive> </mailingList>
Plain Text - Registered: Sun Apr 14 03:35:08 GMT 2024 - Last Modified: Sat Nov 09 12:45:14 GMT 2019 - 3.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/StringCatcher.java
*/ public class StringCatcher { private List<String> events = Lists.newArrayList(); @Subscribe public void hereHaveAString(@Nullable String string) { events.add(string); } public void methodWithoutAnnotation(@Nullable String string) { Assert.fail("Event bus must not call methods without @Subscribe!"); } public List<String> getEvents() { return events; }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed May 16 22:49:59 GMT 2018 - 1.4K bytes - Viewed (0) -
cmd/background-heal-ops.go
} func activeListeners() int { // Bucket notification and http trace are not costly, it is okay to ignore them // while counting the number of concurrent connections return int(globalHTTPListen.Subscribers()) + int(globalTrace.Subscribers()) } func waitForLowIO(maxIO int, maxWait time.Duration, currentIO func() int) { // No need to wait run at full speed. if maxIO <= 0 { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/outside/NeitherAbstractNorAnnotatedInSuperclassTest.java
*/ package com.google.common.eventbus.outside; import static com.google.common.truth.Truth.assertThat; import com.google.common.collect.Lists; import com.google.common.eventbus.Subscribe; import com.google.common.eventbus.outside.NeitherAbstractNorAnnotatedInSuperclassTest.SubClass; import java.util.List; public class NeitherAbstractNorAnnotatedInSuperclassTest extends AbstractEventBusTest<SubClass> {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 08 21:35:40 GMT 2022 - 2.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/outside/NeitherAbstractNorAnnotatedInSuperclassTest.java
*/ package com.google.common.eventbus.outside; import static com.google.common.truth.Truth.assertThat; import com.google.common.collect.Lists; import com.google.common.eventbus.Subscribe; import com.google.common.eventbus.outside.NeitherAbstractNorAnnotatedInSuperclassTest.SubClass; import java.util.List; public class NeitherAbstractNorAnnotatedInSuperclassTest extends AbstractEventBusTest<SubClass> {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 08 21:35:40 GMT 2022 - 2.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/outside/OutsideEventBusTest.java
* limitations under the License. */ package com.google.common.eventbus.outside; import com.google.common.eventbus.EventBus; import com.google.common.eventbus.Subscribe; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReference; import junit.framework.TestCase; /** * Test cases for {@code EventBus} that must not be in the same package. *
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue May 15 20:25:06 GMT 2018 - 1.8K bytes - Viewed (0)