BlackForestBytes/goext
19
0
Fork 0
Code Actions Activity

v0.0.600
Some checks failed
Build Docker and Deploy / Run goext test-suite (push) Failing after 2m30s
Details

Browse Source
This commit is contained in:
Mike Schwörer
2025-09-13 18:45:23 +02:00
parent dc62bbe55f
commit a58bb4b14b
3 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
dataext/broadcaster.go
View File

@@ -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),

18
dataext/broadcaster_test.go
View File

@@ -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)

4
goextVersion.go
View File

@@ -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"