CR: use val, ok syntax

cloudquery · Oct 2, 2024 · 512d6c0 · 512d6c0
1 parent a22c9bd
commit 512d6c0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/writers/streamingbatchwriter/streamingbatchwriter.go b/writers/streamingbatchwriter/streamingbatchwriter.go
@@ -184,8 +184,8 @@ func (w *StreamingBatchWriter) Write(ctx context.Context, msgs <-chan message.Wr
 
 	for {
 		select {
-		case msg := <-msgs:
-			if msg == nil {
+		case msg, ok := <-msgs:
+			if !ok {
 				return w.Close(ctx)
 			}