Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for subscribe (0.06 sec)

  1. android/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
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 15:46:17 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/eventbus/EventBusTest.java

        RuntimeException exception = new RuntimeException("but culottes have a tendency to ride up!");
        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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  3. 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) {
            CopyOnWriteArraySet<Subscriber> newSet = new CopyOnWriteArraySet<>();
            eventSubscribers =
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Jul 08 18:32:10 UTC 2025
    - 10.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.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  5. docs/en/docs/help-fastapi.md

    Or would you like to get help with **FastAPI**?
    
    There are very simple ways to help (several involve just one or two clicks).
    
    And there are several ways to get help too.
    
    ## Subscribe to the newsletter { #subscribe-to-the-newsletter }
    
    You can subscribe to the (infrequent) [**FastAPI and friends** newsletter](newsletter.md){.internal-link target=_blank} to stay updated about:
    
    * News about FastAPI and friends 🚀
    * Guides 📝
    * Features ✨
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 10:49:48 UTC 2025
    - 14K bytes
    - Viewed (0)
  6. 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>
      <div id="announce-right" style="position: relative;">
        <div class="item">
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 15:19:49 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  7. docs/bucket/notifications/README.md

          if c.NatsConn() != nil {
           c.NatsConn().Close()
          }
          _ = c.Close()
         }))
         if stanConnection != nil {
          subscribe()
         }
    
        }
       }
    
      }()
     }))
    
     // Subscribe to subject
     subscribe()
    
     // Keep the connection alive
     runtime.Goexit()
    }
    
    ```
    
    ```
    go run nats.go
    2017/07/07 11:47:40 Connected
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K bytes
    - Viewed (0)
  8. docs/en/docs/contributing.md

    ///
    
    * Check if there's a <a href="https://github.com/fastapi/fastapi/discussions/categories/translations" class="external-link" target="_blank">GitHub Discussion</a> to coordinate translations for your language. You can subscribe to it, and when there's a new pull request to review, an automatic comment will be added to the discussion.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sat Jul 26 11:35:42 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  9. cmd/admin-handlers.go

    	}, nil)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	// Publish bootstrap events that have already occurred before client could subscribe.
    	if traceOpts.TraceTypes().Contains(madmin.TraceBootstrap) {
    		go globalBootstrapTracer.Publish(ctx, globalTrace)
    	}
    
    	for _, peer := range peers {
    		if peer == nil {
    			continue
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  10. api/maven-api-model/src/main/mdo/maven.mdo

              </description>
              <type>String</type>
            </field>
            <field>
              <name>subscribe</name>
              <version>3.0.0+</version>
              <description>
                The email address or link that can be used to subscribe to
                the mailing list.  If this is an email address, a
                {@code mailto:} link will automatically be created
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Thu Aug 07 14:32:16 UTC 2025
    - 132.7K bytes
    - Viewed (0)
Back to top