test(events): add synctest to subscriber tests (#5266)

Author: akrem-chabchoub

pkg/storer/internal/events/subscribe_test.go

@@ -6,54 +6,55 @@ package events_test
 
 import (
 	"testing"
+	"testing/synctest"
 	"time"
 
 	"github.com/ethersphere/bee/v2/pkg/storer/internal/events"
 )
 
 func TestSubscriber(t *testing.T) {
-	t.Parallel()
-
-	s := events.NewSubscriber()
-
-	bin0_1, unsub0_1 := s.Subscribe("0")
-	bin0_2, unsub0_2 := s.Subscribe("0")
-	t.Cleanup(func() { unsub0_1(); unsub0_2() })
-	go s.Trigger("0")
-
-	gotSignals := make(chan struct{})
-
-	go func() {
-		defer close(gotSignals)
-		<-bin0_1
-		<-bin0_2
-	}()
-
-	select {
-	case <-gotSignals:
-	case <-time.After(time.Second):
-		t.Fatal("signals did not fire in time")
-	}
-
-	select {
-	case <-bin0_1:
-		t.Fatalf("trigger should not have fired again")
-	case <-bin0_2:
-		t.Fatalf("trigger should not have fired again")
-	default:
-	}
-
-	bin1, unsub1 := s.Subscribe("1")
-	go s.Trigger("1")
-	go s.Trigger("1")
-	<-bin1
-	<-bin1
-
-	unsub1()
-
-	select {
-	case <-bin1:
-		t.Fatalf("trigger should not have fired again")
-	default:
-	}
+	synctest.Test(t, func(t *testing.T) {
+		s := events.NewSubscriber()
+
+		bin0_1, unsub0_1 := s.Subscribe("0")
+		bin0_2, unsub0_2 := s.Subscribe("0")
+		t.Cleanup(func() { unsub0_1(); unsub0_2() })
+		go s.Trigger("0")
+
+		gotSignals := make(chan struct{})
+
+		go func() {
+			defer close(gotSignals)
+			<-bin0_1
+			<-bin0_2
+		}()
+
+		select {
+		case <-gotSignals:
+		case <-time.After(time.Second):
+			t.Fatal("signals did not fire in time")
+		}
+
+		select {
+		case <-bin0_1:
+			t.Fatalf("trigger should not have fired again")
+		case <-bin0_2:
+			t.Fatalf("trigger should not have fired again")
+		default:
+		}
+
+		bin1, unsub1 := s.Subscribe("1")
+		go s.Trigger("1")
+		go s.Trigger("1")
+		<-bin1
+		<-bin1
+
+		unsub1()
+
+		select {
+		case <-bin1:
+			t.Fatalf("trigger should not have fired again")
+		default:
+		}
+	})
 }