Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for Subscribe (0.19 sec)

  1. 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)
  2. 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 May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 21 18:32:41 GMT 2024
    - 11.3K 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")
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  4. 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.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  5. maven-api-impl/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>******@****.***</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>
    Plain Text
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Thu May 02 15:10:38 GMT 2024
    - 8.6K bytes
    - Viewed (0)
  6. maven-core/src/test/resources/apiv4-repo/commons-logging/commons-logging/1.0.4/commons-logging-1.0.4.pom

          <name>Commons Dev List</name>
          <subscribe>commons-dev-subscribe@jakarta.apache.org</subscribe>
          <unsubscribe>******@****.***</unsubscribe>
          <archive>http://nagoya.apache.org/eyebrowse/SummarizeList?listName=******@****.***</archive>
        </mailingList>
        <mailingList>
          <name>Commons User List</name>
          <subscribe>commons-user-subscribe@jakarta.apache.org</subscribe>
    Plain Text
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Tue Dec 19 19:08:55 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  7. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 16:57:30 GMT 2024
    - 5.2K bytes
    - Viewed (0)
  8. maven-api-impl/src/test/remote-repo/org/apache/apache/1/apache-1.pom

        </snapshotRepository>
      </distributionManagement>
      <mailingLists>
        <mailingList>
          <name>Apache Announce List</name>
          <subscribe>announce-subscribe@apache.org</subscribe>
          <unsubscribe>******@****.***</unsubscribe>
          <post>******@****.***</post>
          <archive>http://mail-archives.apache.org/mod_mbox/www-announce/</archive>
        </mailingList>
    Plain Text
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Thu May 02 15:10:38 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  9. maven-api-impl/src/test/remote-repo/org/apache/maven/maven-plugin-api/2.0/maven-plugin-api-2.0.jar

    http://jira.codehaus.org/browse/MNG continuum ******@****.*** Maven User List users-subscribe@maven.apache.org ******@****.*** ******@****.*** http://mail-archives.apache.org/mod_mbox/maven-users Maven Developer List dev-subscribe@maven.apache.org ******@****.*** ******@****.*** http://mail-archives.apache.org/mod_mbox/maven-dev Maven Commits List commits-subscribe@maven.apache.org ******@****.*** ******@****.*** http:...
    Archive
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Thu May 02 15:10:38 GMT 2024
    - 9.9K bytes
    - Viewed (0)
  10. docs/en/overrides/main.html

        </div>
        <div class="item">
          <a class="announce-link" href="https://fastapi.tiangolo.com/newsletter/">
            <span class="twemoji">
              {% include ".icons/material/email.svg" %}
            </span> Subscribe to the <strong>FastAPI and friends</strong> newsletter 🎉
          </a>
        </div>
        <div class="item">
    HTML
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Mon Mar 25 23:10:11 GMT 2024
    - 4.6K bytes
    - Viewed (0)
Back to top