Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 101 for subscribe (0.25 sec)

  1. android/guava/src/com/google/common/eventbus/Subscribe.java

     *
     * <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)
    @ElementTypesAreNonnullByDefault
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Apr 22 13:05:46 GMT 2021
    - 1.5K bytes
    - Viewed (0)
  2. maven-core/src/test/resources/org/apache/maven/extension/test-extension-repo/org/codehaus/plexus/plexus/1.0.9/plexus-1.0.9.pom

          <unsubscribe>http://xircles.codehaus.org/manage_email/dev%40plexus.codehaus.org</unsubscribe>
          <archive>http://archive.plexus.codehaus.org/dev</archive>
        </mailingList>
        <mailingList>
          <name>Plexus Announce List</name>
          <subscribe>http://xircles.codehaus.org/manage_email/announce%40plexus.codehaus.org</subscribe>
          <unsubscribe>http://xircles.codehaus.org/manage_email/announce%40plexus.codehaus.org</unsubscribe>
    Plain Text
    - Registered: Sun Mar 31 03:35:09 GMT 2024
    - Last Modified: Thu Dec 24 18:09:10 GMT 2020
    - 7.5K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/eventbus/outside/AnnotatedNotAbstractInSuperclassTest.java

        @Subscribe
        public void notOverriddenInSubclass(Object o) {
          notOverriddenInSubclassEvents.add(o);
        }
    
        @Subscribe
        public void overriddenNotAnnotatedInSubclass(Object o) {
          overriddenNotAnnotatedInSubclassEvents.add(o);
        }
    
        @Subscribe
        public void overriddenAndAnnotatedInSubclass(Object o) {
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Tue Feb 08 21:35:40 GMT 2022
    - 4.1K bytes
    - Viewed (0)
  4. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/eventbus/DispatcherTest.java

            .containsExactly(
                i1, s1, s2, // Each integer subscriber immediately dispatches to 2 string subscribers.
                i2, s1, s2, i3, s1, s2)
            .inOrder();
      }
    
      private static Subscriber subscriber(
          EventBus bus, Object target, String methodName, Class<?> eventType) {
        try {
          return Subscriber.create(bus, target, target.getClass().getMethod(methodName, eventType));
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Apr 27 15:41:25 GMT 2022
    - 5.6K bytes
    - Viewed (0)
  6. 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 Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Feb 21 18:32:41 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  7. 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)
  8. guava-tests/test/com/google/common/eventbus/outside/AnnotatedAndAbstractInSuperclassTest.java

    import com.google.common.eventbus.Subscribe;
    import com.google.common.eventbus.outside.AnnotatedAndAbstractInSuperclassTest.SubClass;
    import java.util.List;
    
    public class AnnotatedAndAbstractInSuperclassTest extends AbstractEventBusTest<SubClass> {
      abstract static class SuperClass {
        @Subscribe
        public abstract void overriddenAndAnnotatedInSubclass(Object o);
    
        @Subscribe
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Tue Feb 08 21:35:40 GMT 2022
    - 2K bytes
    - Viewed (0)
  9. maven-core/src/test/resources/apiv4-repo/org/codehaus/plexus/plexus/1.0.10/plexus-1.0.10.pom

          <unsubscribe>http://xircles.codehaus.org/manage_email/dev%40plexus.codehaus.org</unsubscribe>
          <archive>http://archive.plexus.codehaus.org/dev</archive>
        </mailingList>
        <mailingList>
          <name>Plexus Announce List</name>
          <subscribe>http://xircles.codehaus.org/manage_email/announce%40plexus.codehaus.org</subscribe>
          <unsubscribe>http://xircles.codehaus.org/manage_email/announce%40plexus.codehaus.org</unsubscribe>
    Plain Text
    - Registered: Sun Apr 21 03:35:09 GMT 2024
    - Last Modified: Sun Oct 02 08:41:25 GMT 2022
    - 7.8K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/eventbus/outside/AnnotatedNotAbstractInSuperclassTest.java

        @Subscribe
        public void notOverriddenInSubclass(Object o) {
          notOverriddenInSubclassEvents.add(o);
        }
    
        @Subscribe
        public void overriddenNotAnnotatedInSubclass(Object o) {
          overriddenNotAnnotatedInSubclassEvents.add(o);
        }
    
        @Subscribe
        public void overriddenAndAnnotatedInSubclass(Object o) {
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Tue Feb 08 21:35:40 GMT 2022
    - 4.1K bytes
    - Viewed (0)
Back to top