diff options
Diffstat (limited to 'worker/mbox/io.go')
| -rw-r--r-- | worker/mbox/io.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/worker/mbox/io.go b/worker/mbox/io.go index 38469160..67290482 100644 --- a/worker/mbox/io.go +++ b/worker/mbox/io.go @@ -1,6 +1,7 @@ package mboxer import ( + "errors" "io" "io/ioutil" "time" @@ -16,7 +17,7 @@ func Read(r io.Reader) ([]lib.RawMessage, error) { messages := make([]lib.RawMessage, 0) for { msg, err := mbr.NextMessage() - if err == io.EOF { + if errors.Is(err, io.EOF) { break } else if err != nil { return nil, err |