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 |
} |
} |
} |