| Index: impl/prod/raw_datastore.go
|
| diff --git a/impl/prod/raw_datastore.go b/impl/prod/raw_datastore.go
|
| index e70b31adb06670de9cbcdab4a238626571dbcb8b..2353818040022f93afbc61bbd8c08c7c02a6d425 100644
|
| --- a/impl/prod/raw_datastore.go
|
| +++ b/impl/prod/raw_datastore.go
|
| @@ -216,8 +216,11 @@ func (d rdsImpl) Run(fq *ds.FinalizedQuery, cb ds.RawRunCB) error {
|
| if err != nil {
|
| return err
|
| }
|
| - if !cb(dsR2F(k), tf.pm, cfunc) {
|
| - return nil
|
| + if err := cb(dsR2F(k), tf.pm, cfunc); err != nil {
|
| + if err == ds.Stop {
|
| + return nil
|
| + }
|
| + return err
|
| }
|
| }
|
| }
|
|
|