diff --git a/dataext/broadcaster.go b/dataext/broadcaster.go index 04c5069..00b60f7 100644 --- a/dataext/broadcaster.go +++ b/dataext/broadcaster.go @@ -40,7 +40,7 @@ func (p *broadcastSubscription[TData]) Unsubscribe() { p.parent.unsubscribe(p) } -func NewBroadcast[TData any](capacity int) *Broadcaster[TData] { +func NewBroadcaster[TData any](capacity int) *Broadcaster[TData] { return &Broadcaster[TData]{ masterLock: &sync.Mutex{}, subscriptions: make([]*broadcastSubscription[TData], 0, capacity), diff --git a/dataext/broadcaster_test.go b/dataext/broadcaster_test.go index 31c46ff..c41d89e 100644 --- a/dataext/broadcaster_test.go +++ b/dataext/broadcaster_test.go @@ -8,9 +8,9 @@ import ( ) func TestNewBroadcast(t *testing.T) { - bb := NewBroadcast[string](10) + bb := NewBroadcaster[string](10) if bb == nil { - t.Fatal("NewBroadcast returned nil") + t.Fatal("NewBroadcaster returned nil") } if bb.masterLock == nil { t.Fatal("masterLock is nil") @@ -21,7 +21,7 @@ func TestNewBroadcast(t *testing.T) { } func TestBroadcast_SubscribeByCallback(t *testing.T) { - bb := NewBroadcast[string](10) + bb := NewBroadcaster[string](10) var received string var wg sync.WaitGroup @@ -55,7 +55,7 @@ func TestBroadcast_SubscribeByCallback(t *testing.T) { } func TestBroadcast_SubscribeByChan(t *testing.T) { - bb := NewBroadcast[string](10) + bb := NewBroadcaster[string](10) ch, sub := bb.SubscribeByChan(1) defer sub.Unsubscribe() @@ -83,7 +83,7 @@ func TestBroadcast_SubscribeByChan(t *testing.T) { } func TestBroadcast_SubscribeByIter(t *testing.T) { - bb := NewBroadcast[string](10) + bb := NewBroadcaster[string](10) iterSeq, sub := bb.SubscribeByIter(1) defer sub.Unsubscribe() @@ -126,7 +126,7 @@ func TestBroadcast_SubscribeByIter(t *testing.T) { } func TestBroadcast_Publish(t *testing.T) { - bb := NewBroadcast[string](10) + bb := NewBroadcaster[string](10) // Test publishing with no subscribers subs, receivers := bb.Publish("hello") @@ -176,7 +176,7 @@ func TestBroadcast_Publish(t *testing.T) { } func TestBroadcast_PublishWithTimeout(t *testing.T) { - bb := NewBroadcast[string](10) + bb := NewBroadcaster[string](10) // Add a subscriber with a channel ch, sub := bb.SubscribeByChan(1) @@ -223,7 +223,7 @@ func TestBroadcast_PublishWithTimeout(t *testing.T) { } func TestBroadcast_PublishWithContext(t *testing.T) { - bb := NewBroadcast[string](10) + bb := NewBroadcaster[string](10) // Add a subscriber with a channel ch, sub := bb.SubscribeByChan(1) @@ -289,7 +289,7 @@ func TestBroadcast_PublishWithContext(t *testing.T) { } func TestBroadcast_Unsubscribe(t *testing.T) { - bb := NewBroadcast[string](10) + bb := NewBroadcaster[string](10) // Add a subscriber ch, sub := bb.SubscribeByChan(1) diff --git a/goextVersion.go b/goextVersion.go index c6e88df..8d97dd1 100644 --- a/goextVersion.go +++ b/goextVersion.go @@ -1,5 +1,5 @@ package goext -const GoextVersion = "0.0.599" +const GoextVersion = "0.0.600" -const GoextVersionTimestamp = "2025-09-13T18:42:17+0200" +const GoextVersionTimestamp = "2025-09-13T18:45:23+0200"