- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 70 for subscribe (0.07 seconds)
-
internal/pubsub/pubsub_test.go
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) } ps.Lock() defer ps.Unlock() if len(ps.subs) != 2 || ps.NumSubscribers(MaskAll) != 2 || ps.Subscribers() != 2 { t.Fatalf("expected 2 subscribers") } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Aug 14 17:11:51 GMT 2024 - 5.8K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/interpolation/StringVisitorModelInterpolator.java
mailingList.setName(val); } // Subscribe org = mailingList.getSubscribe(); val = interpolate(org); if (org != val) { mailingList.setSubscribe(val); } // Unsubscribe org = mailingList.getUnsubscribe(); val = interpolate(org);
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Feb 25 08:27:34 GMT 2025 - 43.1K bytes - Click Count (0) -
docs/zh-hant/docs/help-fastapi.md
# 協助 FastAPI - 取得協助 { #help-fastapi-get-help } 你喜歡 **FastAPI** 嗎? 你願意協助 FastAPI、其他使用者,以及作者嗎? 或是你想獲得 **FastAPI** 的協助? 有一些非常簡單的方式可以幫忙(有些只需要點一兩下)。 而且也有多種方式可以取得協助。 ## 訂閱電子報 { #subscribe-to-the-newsletter } 你可以訂閱(不常發送的)[**FastAPI 與夥伴**電子報](newsletter.md),隨時掌握: * 關於 FastAPI 與夥伴的最新消息 🚀 * 教學指南 📝 * 新功能 ✨ * 破壞性變更 🚨 * 小技巧與祕訣 ✅ ## 在 X(Twitter)關注 FastAPI { #follow-fastapi-on-x-twitter }Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 17:05:38 GMT 2026 - 11.9K bytes - Click Count (0) -
docs/zh/docs/help-fastapi.md
# 帮助 FastAPI - 获取帮助 { #help-fastapi-get-help } 你喜欢 **FastAPI** 吗? 想帮助 FastAPI、其他用户和作者吗? 或者你想获取 **FastAPI** 的帮助? 有很多非常简单的方式可以帮忙(有些只需点一两下)。 同样,也有多种途径可以获得帮助。 ## 订阅新闻邮件 { #subscribe-to-the-newsletter } 你可以订阅(不频繁的)[**FastAPI and friends** 新闻邮件](newsletter.md),获取如下更新: * FastAPI 及其小伙伴的新闻 🚀 * 指南 📝 * 功能 ✨ * 破坏性更改 🚨 * 使用技巧 ✅ ## 在 X (Twitter) 上关注 FastAPI { #follow-fastapi-on-x-twitter }Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 17:06:37 GMT 2026 - 11.8K bytes - Click Count (0) -
docs/ja/docs/help-fastapi.md
**FastAPI** は気に入りましたか? FastAPIや他のユーザー、作者を応援したいですか? それとも **FastAPI** についてヘルプが必要ですか? とても簡単に応援できる方法があります(1、2回クリックするだけのものもあります)。 ヘルプを得る方法もいくつかあります。 ## ニュースレターを購読 { #subscribe-to-the-newsletter } [**FastAPI and friends** ニュースレター](newsletter.md)(配信はまれです)を購読すると、次の情報をキャッチアップできます: * FastAPI と関連プロジェクトのニュース 🚀 * ガイド 📝 * 機能 ✨ * 互換性に影響する変更 🚨 * ヒントやコツ ✅Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 14:07:17 GMT 2026 - 15.3K 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) -
compat/maven-model/src/main/java/org/apache/maven/model/merge/ModelMerger.java
if (src != null) { if (sourceDominant || target.getSubscribe() == null) { target.setSubscribe(src); target.setLocation("subscribe", source.getLocation("subscribe")); } } } protected void mergeMailingList_Unsubscribe( MailingList target, MailingList source, boolean sourceDominant, Map<Object, Object> context) {
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Apr 03 11:21:39 GMT 2025 - 99.2K bytes - Click Count (0) -
cmd/listen-notification-handlers.go
case <-ctx.Done(): grid.PutByteBuffer(buf.Bytes()) return } } }() peers, _ := newPeerRestClients(globalEndpoints) err := globalHTTPListen.Subscribe(mask, localCh, ctx.Done(), func(ev event.Event) bool { if ev.S3.Bucket.Name != "" && bucketName != "" { if ev.S3.Bucket.Name != bucketName { return false } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 6K bytes - Click Count (0) -
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 }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 99.7K bytes - Click Count (0) -
api/maven-api-model/src/main/mdo/maven.mdo
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Feb 17 09:48:21 GMT 2026 - 133.5K bytes - Click Count (0)