check close channel before add (#16)

nar10z · Jul 8, 2024 · 3a9dd27 · 3a9dd27
1 parent e3c88e5
commit 3a9dd27
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/accumulator.go b/accumulator.go
@@ -87,10 +87,6 @@ func (a *Accumulator[T]) AddAsync(ctx context.Context, event T) error {
 }
 
 func (a *Accumulator[T]) AddSync(ctx context.Context, event T) error {
-	if a.isClose.Load() {
-		return ErrSendToClose
-	}
-
 	// check context before alloc eventExtended
 	select {
 	case <-ctx.Done():
@@ -103,6 +99,10 @@ func (a *Accumulator[T]) AddSync(ctx context.Context, event T) error {
 		e:        event,
 	}
 
+	if a.isClose.Load() {
+		return ErrSendToClose
+	}
+
 	// check context with write to channel
 	select {
 	case <-ctx.Done():