From 98efc3faaa48ac3c89c3cd28c9ffd9e80f4c6f36 Mon Sep 17 00:00:00 2001 From: Nikita Tokarchuk Date: Thu, 16 May 2019 22:09:19 +0200 Subject: [PATCH] Override cursor Next function with a wrapper --- mongox/common/loadmany.go | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/mongox/common/loadmany.go b/mongox/common/loadmany.go index c328f2c..70dd042 100644 --- a/mongox/common/loadmany.go +++ b/mongox/common/loadmany.go @@ -38,6 +38,17 @@ func (l *ManyLoader) GetNext() error { return nil } +// Next loads next documents but doesn't perform decoding +func (l *ManyLoader) Next() error { + + hasNext := l.Cursor.Next(l.ctx) + if !hasNext { + return errors.NotFoundErrorf("%s", mongo.ErrNoDocuments) + } + + return nil +} + // Close cursor func (l *ManyLoader) Close() error {