- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for Overlaps (0.21 sec)
-
internal/pubsub/mask.go
return Mask(m.Mask()) } // Contains returns whether *all* flags in other is present in t. func (t Mask) Contains(other Mask) bool { return t&other == other } // Overlaps returns whether *any* flags in t overlaps with other. func (t Mask) Overlaps(other Mask) bool { return t&other != 0 } // SingleType returns whether t has a single type set. func (t Mask) SingleType() bool { return bits.OnesCount64(uint64(t)) == 1 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jul 05 21:45:49 GMT 2022 - 1.3K bytes - Viewed (0) -
internal/pubsub/pubsub.go
// and 0 will be returned if nobody is subscribed for the type(s). func (ps *PubSub[T, M]) NumSubscribers(mask M) int32 { types := Mask(atomic.LoadUint64(&ps.types)) if !types.Overlaps(Mask(mask.Mask())) { return 0 } return atomic.LoadInt32(&ps.numSubscribers) } // Subscribers returns the number of current subscribers for all types. func (ps *PubSub[T, M]) Subscribers() int32 {
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) -
internal/pubsub/pubsub_test.go
} // Mask matches maskString, should get result if err := ps.Subscribe(Mask(1|2), ch2, doneCh, func(entry Maskable) bool { return true }); err != nil { t.Fatalf("unexpected error: %v", err) } // Does NOT overlap maskString if err := ps.Subscribe(Mask(2), ch3, doneCh, func(entry Maskable) bool { return true }); err != nil { t.Fatalf("unexpected error: %v", err) } val := maskString("hello") ps.Publish(val)
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)