- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for subscribe (0.3 sec)
-
internal/pubsub/pubsub_test.go
defer close(doneCh) if err := ps.Subscribe(MaskAll, ch1, doneCh, nil); err != nil { t.Fatalf("unexpected error: %v", err) } if err := ps.Subscribe(MaskAll, ch2, doneCh, nil); err != nil { t.Fatalf("unexpected error: %v", err) } ps.Lock() defer ps.Unlock() if len(ps.subs) != 2 || ps.NumSubscribers(MaskAll) != 2 || ps.Subscribers() != 2 { t.Fatalf("expected 2 subscribers") } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/EventBusTest.java
new RuntimeException("but culottes have a tendancy to ride up!"); final Object subscriber = new Object() { @Subscribe public void throwExceptionOn(String message) { throw exception; } }; eventBus.register(subscriber); eventBus.post(EVENT); assertEquals("Cause should be available.", exception, handler.exception);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
new RuntimeException("but culottes have a tendancy to ride up!"); final Object subscriber = new Object() { @Subscribe public void throwExceptionOn(String message) { throw exception; } }; eventBus.register(subscriber); eventBus.post(EVENT); assertEquals("Cause should be available.", exception, handler.exception);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.3K bytes - Viewed (0) -
maven-api-impl/src/test/remote-repo/org/apache/maven/maven/2.0/maven-2.0.pom
<name>Maven User List</name> <subscribe>users-subscribe@maven.apache.org</subscribe> <unsubscribe>users-unsubscribe@maven.apache.org</unsubscribe> <post>******@****.***</post> <archive>http://mail-archives.apache.org/mod_mbox/maven-users</archive> </mailingList> <mailingList> <name>Maven Developer List</name> <subscribe>dev-subscribe@maven.apache.org</subscribe>
Plain Text - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 8.6K bytes - Viewed (0) -
cmd/consolelogger.go
// for this node or peers func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool { return sys != nil && sys.pubsub.Subscribers() > 0 } // Subscribe starts console logging for this node. func (sys *HTTPConsoleLoggerSys) Subscribe(subCh chan log.Info, doneCh <-chan struct{}, node string, last int, logKind madmin.LogMask, filter func(entry log.Info) bool) error { // Enable console logging for remote client.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
maven-core/src/test/projects/plugin-manager/project-with-inheritance/pom.xml
<url>http://jira.codehaus.org/browse/MNG</url> </issueManagement> <mailingLists> <mailingList> <name>Maven Developer List</name> <subscribe>dev-subscribe@maven.apache.org</subscribe> <unsubscribe>dev-unsubscribe@maven.apache.org</unsubscribe> <post>******@****.***</post> <archive>http://mail-archives.apache.org/mod_mbox/maven-dev</archive> <otherArchives>
XML - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Thu Aug 03 09:29:10 GMT 2023 - 22.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/SubscriberTest.java
} public void testCreate() { Subscriber s1 = Subscriber.create(bus, this, getTestSubscriberMethod("recordingMethod")); assertThat(s1).isInstanceOf(Subscriber.SynchronizedSubscriber.class); // a thread-safe method should not create a synchronized subscriber Subscriber s2 = Subscriber.create(bus, this, getTestSubscriberMethod("threadSafeMethod")); assertThat(s2).isNotInstanceOf(Subscriber.SynchronizedSubscriber.class); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.8K bytes - Viewed (0) -
maven-core/src/test/resources/apiv4-repo/commons-logging/commons-logging/1.0.4/commons-logging-1.0.4.pom
<name>Commons Dev List</name> <subscribe>commons-dev-subscribe@jakarta.apache.org</subscribe> <unsubscribe>commons-dev-unsubscribe@jakarta.apache.org</unsubscribe> <archive>http://nagoya.apache.org/eyebrowse/SummarizeList?listName=******@****.***</archive> </mailingList> <mailingList> <name>Commons User List</name> <subscribe>commons-user-subscribe@jakarta.apache.org</subscribe>
Plain Text - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Tue Dec 19 19:08:55 GMT 2023 - 5.1K bytes - Viewed (0) -
internal/pubsub/pubsub.go
default: } } } } // Subscribe - Adds a subscriber to pubsub system func (ps *PubSub[T, M]) Subscribe(mask M, subCh chan T, doneCh <-chan struct{}, filter func(entry T) bool) error { totalSubs := atomic.AddInt32(&ps.numSubscribers, 1) if ps.maxSubscribers > 0 && totalSubs > ps.maxSubscribers { atomic.AddInt32(&ps.numSubscribers, -1) return fmt.Errorf("the limit of `%d` subscribers is reached", ps.maxSubscribers) } ps.Lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/SubscriberRegistryTest.java
Iterator<Subscriber> two = registry.getSubscribers(""); assertEquals(s1, two.next().target); assertEquals(o1, two.next().target); assertFalse(two.hasNext()); } public static class StringSubscriber { @Subscribe public void handle(String s) {} } public static class IntegerSubscriber { @Subscribe public void handle(Integer i) {} }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 5.7K bytes - Viewed (0)