Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 48 for Subscribe (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 08 21:35:40 UTC 2022
    - 4.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/eventbus/outside/DeepInterfaceTest.java

    import com.google.common.eventbus.Subscribe;
    import com.google.common.eventbus.outside.DeepInterfaceTest.SubscriberClass;
    import java.util.List;
    
    public class DeepInterfaceTest extends AbstractEventBusTest<SubscriberClass> {
      interface Interface1 {
        @Subscribe
        void annotatedIn1(Object o);
    
        @Subscribe
        void annotatedIn1And2(Object o);
    
        @Subscribe
        void annotatedIn1And2AndClass(Object o);
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 08 21:35:40 UTC 2022
    - 4.2K bytes
    - Viewed (0)
  6. 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);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  7. 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)
  8. android/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) {}
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  9. android/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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 08 21:35:40 UTC 2022
    - 2K bytes
    - Viewed (0)
  10. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 08 21:35:40 UTC 2022
    - 2K bytes
    - Viewed (0)
Back to top