- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 36 for subscribe (0.14 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
guava/src/com/google/common/eventbus/Subscribe.java
* the {@link EventBus}. * * <p>Unless also annotated with @{@link AllowConcurrentEvents}, event subscriber methods will be * invoked serially by each event bus that they are registered with. * * @author Cliff Biffle * @since 10.0 */ @Retention(RetentionPolicy.RUNTIME) @Target(ElementType.METHOD) @KeepCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Jul 16 15:46:17 GMT 2025 - 1.5K bytes - Click Count (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()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Click Count (0) -
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") } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Aug 14 17:11:51 GMT 2024 - 5.8K bytes - Click Count (0) -
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@mailing.list.com</unsubscribe> </mailingList> </mailingLists> <build> <plugins> <plugin> <groupId>inheritance.configuration</groupId>
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 2.7K bytes - Click Count (0) -
impl/maven-core/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>
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 8.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/eventbus/ReentrantEventsTest.java
boolean ready = true; final List<Object> eventsReceived = new ArrayList<>(); @Subscribe public void listenForStrings(String event) { eventsReceived.add(event); ready = false; try { bus.post(SECOND); } finally { ready = true; } } @Subscribe public void listenForDoubles(Double event) {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 2.6K bytes - Click Count (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@mailing.list.com</unsubscribe> <post>******@****.***</post> </mailingList> </mailingLists> <build> <plugins> <plugin>
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 2.9K bytes - Click Count (0) -
compat/maven-model-builder/src/test/resources/poms/inheritance/plugin-configuration-child.xml
<!--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@mailing.list.com</unsubscribe> </mailingList--> </mailingLists> <build> <plugins> <plugin> <groupId>inheritance.configuration</groupId>Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 2K bytes - Click Count (0) -
android/guava/src/com/google/common/eventbus/AllowConcurrentEvents.java
import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * Marks an event subscriber method as being thread-safe. This annotation indicates that EventBus * may invoke the event subscriber simultaneously from multiple threads. * * <p>This does not mark the method, and so should be used in combination with {@link Subscribe}. * * @author Cliff Biffle * @since 10.0 */ @Retention(RetentionPolicy.RUNTIME)Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 1.2K bytes - Click Count (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) {} }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 5.8K bytes - Click Count (0)