Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 36 for subscribe (0.14 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
    @Keep
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jul 16 15:46:17 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top