- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 69 for subscriber (0.09 seconds)
-
.github/ISSUE_TEMPLATE.md
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sat Jan 29 00:04:16 GMT 2022 - 2K bytes - Click Count (0) -
cmd/peer-rest-server.go
// Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers. // Use buffered channel to take care of burst sends or slow w.Write() ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity()) err := globalHTTPListen.Subscribe(mask, ch, ctx.Done(), func(ev event.Event) bool { if ev.S3.Bucket.Name != "" && values.Get(peerRESTListenBucket) != "" {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 53.6K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/eventbus/EventBusBenchmark.java
eventBus.register(this); } @Benchmark void postStrings(int reps) { for (int i = 0; i < reps; i++) { eventBus.post("hello there"); } } @Subscribe public void handleStrings(String string) { // Nothing to do here. }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 1.2K bytes - Click Count (0) -
android/guava/src/com/google/common/eventbus/package-info.java
* the License. */ /** * {@linkplain EventBus Discouraged} in favor of dependency injection and concurrency frameworks, * EventBus allows publish-subscribe-style communication. * * <p>See the Guava User Guide article on <a * href="https://github.com/google/guava/wiki/EventBusExplained">{@code EventBus}</a>. */ @CheckReturnValue @NullMarkedCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jan 03 19:02:39 GMT 2025 - 1K bytes - Click Count (0) -
android/guava/src/com/google/common/eventbus/AsyncEventBus.java
* down the executor after the last event has been posted to this event bus. * @param subscriberExceptionHandler Handler used to handle exceptions thrown from subscribers. * See {@link SubscriberExceptionHandler} for more information. * @since 16.0 */ public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 2.5K bytes - Click Count (0) -
cmd/http-tracer.go
reqStartTime := time.Now().UTC() h.ServeHTTP(respRecorder, r) reqEndTime := time.Now().UTC() if globalTrace.NumSubscribers(madmin.TraceS3|madmin.TraceInternal) == 0 { // no subscribers nothing to trace. return } tt := madmin.TraceInternal if strings.HasPrefix(tc.FuncName, "s3.") { tt = madmin.TraceS3 } // Calculate input body size with headers
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Sep 24 17:13:00 GMT 2024 - 6K bytes - Click Count (0) -
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) to stay updated about: * News about FastAPI and friends 🚀 * Guides 📝 * Features ✨ * Breaking changes 🚨
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 12.6K bytes - Click Count (0) -
docs/en/docs/js/custom.js
} catch (_) {} }); } async function main() { setupTermynal(); showRandomAnnouncement('announce-left', 5000) handleSponsorImages(); openLinksInNewTab(); } document$.subscribe(() => { main()
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 17:59:48 GMT 2026 - 7.7K bytes - Click Count (2) -
docs/en/docs/contributing.md
#### Subscribe to Notifications for Your Language Check if there's a [GitHub Discussion](https://github.com/fastapi/fastapi/discussions/categories/translations) 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.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Mon Mar 23 13:59:26 GMT 2026 - 10.6K bytes - Click Count (0) -
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">Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Mon Dec 01 20:06:57 GMT 2025 - 5.5K bytes - Click Count (0)