Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for Overlaps (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top