diff --git a/req.go b/req.go index efb22ce..2f0386c 100644 --- a/req.go +++ b/req.go @@ -215,8 +215,11 @@ example: if err := easyjson.Unmarshal([]byte(scanner.Text()), &evt); err != nil { continue } - if err := store.SaveEvent(evt); err != nil || err == eventstore.ErrDupEvent { - continue + if err := store.SaveEvent(evt); err != nil { + if err == eventstore.ErrDupEvent { + continue + } + return fmt.Errorf("failed to save event from sync file: %w", err) } } if err := scanner.Err(); err != nil {