- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for HasTable (0.14 sec)
-
internal/pubsub/pubsub.go
var GetByteBuffer = func() []byte { return make([]byte, 0, 4096) } // Sub - subscriber entity. type Sub[T Maskable] struct { ch chan T types Mask filter func(entry T) bool } // PubSub holds publishers and subscribers type PubSub[T Maskable, M Maskable] struct { // atomics, keep at top: types uint64 numSubscribers int32 maxSubscribers int32 // not atomics:
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
func TestMultiPubSub(t *testing.T) { ps := New[Maskable, Maskable](2) ch1 := make(chan Maskable, 1) ch2 := make(chan Maskable, 1) doneCh := make(chan struct{}) defer close(doneCh) if err := ps.Subscribe(MaskAll, ch1, doneCh, func(entry Maskable) bool { return true }); err != nil { t.Fatalf("unexpected error: %v", err) } if err := ps.Subscribe(MaskAll, ch2, doneCh, func(entry Maskable) bool { return true }); err != nil {
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) -
internal/pubsub/mask.go
func (t *Mask) MergeMaskable(other Maskable) { *t |= Mask(other.Mask()) } // SetIf will add other if b is true. func (t *Mask) SetIf(b bool, other Mask) { if b { *t |= other } } // Mask returns the mask as a uint64. func (t Mask) Mask() uint64 { return uint64(t) } // Maskable implementations must return their mask as a 64 bit uint. type Maskable interface { Mask() uint64
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)