From 07fed4b4eb9f54de81e3a836bfb20a2584bc92eb Mon Sep 17 00:00:00 2001 From: Gregory Eremin Date: Sun, 11 Nov 2018 20:35:31 +0100 Subject: [PATCH] Decode first, return second --- reader/reader.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/reader/reader.go b/reader/reader.go index 04da44c..f939019 100644 --- a/reader/reader.go +++ b/reader/reader.go @@ -155,5 +155,6 @@ func (e Event) DecodeRows() (binlog.RowsEvent, error) { if binlog.RowsEventVersion(e.Header.Type) < 0 { return re, errors.New("invalid rows event") } - return re, re.Decode(e.Buffer, e.Format, *e.Table) + err := re.Decode(e.Buffer, e.Format, *e.Table) + return re, err }