libp2p/go-libp2p-core
1
0
Fork 0
mirror of https://github.com/libp2p/go-libp2p-core.git synced 2025-01-28 04:30:08 +08:00
Code Issues Projects Releases Wiki Activity

Merge pull request #147 from libp2p/feat/subscribes-to-events

Browse Source 
feat: add a function to tell if a context subscribes to query events
This commit is contained in:
Steven Allen 2020-04-29 13:21:46 -07:00 committed by GitHub
commit a4b837bc12
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
routing/query.go
View File

@ -102,3 +102,10 @@ func PublishQueryEvent(ctx context.Context, ev *QueryEvent) {
ech := ich.(*eventChannel) ech := ich.(*eventChannel)
ech.send(ctx, ev) ech.send(ctx, ev)
} }
// SubscribesToQueryEvents returns true if the context subscribes to query
// events. If this function returns falls, calling `PublishQueryEvent` on the
// context will be a no-op.
func SubscribesToQueryEvents(ctx context.Context) bool {
return ctx.Value(routingQueryKey{}) != nil
}