Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for Subscribe (0.12 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/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)
  5. 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)
  6. 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)
  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>
          <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)
  8. 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)
  9. 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)
  10. 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)
Back to top