Refactor BatchHandler

core-go · Jun 30, 2024 · 70b5ee4 · 70b5ee4
1 parent 8104d8a
commit 70b5ee4
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/batch_handler.go b/batch_handler.go
@@ -27,15 +27,13 @@ func (h *BatchHandler[T]) Handle(ctx context.Context, data []Message[T]) ([]Mess
 			vs = append(vs, message.Value)
 		}
 		failIndices, err := h.Write(ctx, vs)
-		if err != nil {
-			return failMessages, err
-		}
 		sl := len(failIndices)
 		if sl > 0 {
 			for j := 0; j < sl; j++ {
 				failMessages = append(failMessages, data[failIndices[j]])
 			}
 		}
+		return failMessages, err
 	}
 	return failMessages, nil
 }