- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for Subscribe (0.12 sec)
-
compat/maven-model-builder/src/test/resources/poms/inheritance/plugin-configuration-parent.xml
<url>http://www.apache.org/</url> <mailingLists> <mailingList> <name>parent</name> <post>******@****.***</post> <subscribe>subscribe@mailing.list.com</subscribe> <unsubscribe>******@****.***</unsubscribe> </mailingList> </mailingLists> <build> <plugins> <plugin> <groupId>inheritance.configuration</groupId>
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
new RuntimeException("but culottes have a tendency 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);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 15:16:45 UTC 2024 - 11.2K bytes - Viewed (0) -
internal/pubsub/pubsub_test.go
ch3 := make(chan Maskable, 1) doneCh := make(chan struct{}) 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) } if err := ps.Subscribe(MaskAll, ch3, doneCh, nil); err == nil { t.Fatalf("unexpected nil err") } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 5.8K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/SubscriberRegistry.java
for (Entry<Class<?>, Collection<Subscriber>> entry : listenerMethods.asMap().entrySet()) { Class<?> eventType = entry.getKey(); Collection<Subscriber> eventMethodsInListener = entry.getValue(); CopyOnWriteArraySet<Subscriber> eventSubscribers = subscribers.get(eventType); if (eventSubscribers == null) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 15:16:45 UTC 2024 - 10.8K bytes - Viewed (0) -
compat/maven-model-builder/src/test/resources/poms/inheritance/plugin-configuration-child.xml
<mailingLists> <!--mailingList> MNG-3124: no way to add a list to parent content, only full override <name>child</name> <post>******@****.***</post> <subscribe>subscribe@mailing.list.com</subscribe> <unsubscribe>******@****.***</unsubscribe> </mailingList--> </mailingLists> <build> <plugins> <plugin>
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2K 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.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
compat/maven-model-builder/src/test/resources/poms/inheritance/plugin-configuration-expected.xml
<url>http://www.apache.org/child/</url><!-- child's artifactId appended to parent url --> <mailingLists> <mailingList> <name>parent</name> <subscribe>subscribe@mailing.list.com</subscribe> <unsubscribe>******@****.***</unsubscribe> <post>******@****.***</post> </mailingList> </mailingLists> <build> <plugins> <plugin>
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2.9K bytes - Viewed (0) -
internal/pubsub/pubsub.go
if sub.types.Contains(Mask(item.Mask())) && (sub.filter == nil || sub.filter(item)) { select { case sub.ch <- item: 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 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/PackageSanityTests.java
} private static class DummySubscriber { private final EventBus eventBus = new EventBus(); @Subscribe public void handle(@Nullable Object unused) {} Subscriber toSubscriber() throws Exception { return Subscriber.create(eventBus, this, subscriberMethod()); } SubscriberExceptionContext toContext() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jul 02 18:21:29 UTC 2024 - 1.9K bytes - Viewed (0) -
docs/en/docs/js/custom.js
ul.append(li) }) } setupTermynal(); showRandomAnnouncement('announce-left', 5000) showRandomAnnouncement('announce-right', 10000) } document$.subscribe(() => { main()
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 6.6K bytes - Viewed (0)