From 04382db4cd1715583643c907f9264a117caacf78 Mon Sep 17 00:00:00 2001 From: Nikita Tokarchuk Date: Mon, 8 Mar 2021 08:19:44 +0100 Subject: [PATCH] Remove usesd ref interface from the stream loader --- mongox/database/loadstream.go | 2 +- mongox/database/streamloader.go | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/mongox/database/loadstream.go b/mongox/database/loadstream.go index 017e71d..cbeadb9 100644 --- a/mongox/database/loadstream.go +++ b/mongox/database/loadstream.go @@ -30,7 +30,7 @@ func (d *Database) LoadStream(target interface{}, filters ...interface{}) (loade return } - loader = &StreamLoader{cur: cursor, ctx: ctx, ref: target, query: composed} + loader = &StreamLoader{cur: cursor, ctx: ctx, query: composed} return } diff --git a/mongox/database/streamloader.go b/mongox/database/streamloader.go index 4aca640..dbe8989 100644 --- a/mongox/database/streamloader.go +++ b/mongox/database/streamloader.go @@ -13,7 +13,6 @@ type StreamLoader struct { cur *mongox.Cursor query *query.Query ctx context.Context - ref interface{} } // DecodeNextMsg decodes the next document to an interface or returns an error @@ -80,7 +79,7 @@ func (l *StreamLoader) Cursor() (cursor *mongox.Cursor) { func (l *StreamLoader) Close() (err error) { closerr := l.cur.Close(l.ctx) - invokerr := l.query.OnClose().Invoke(l.ctx, l.ref) + invokerr := l.query.OnClose().Invoke(l.ctx, nil) if closerr != nil { err = closerr