Index: impl/memory/datastore.go |
diff --git a/impl/memory/datastore.go b/impl/memory/datastore.go |
index 857b06e307a686b38eef483c4e650fb3467ea6b3..2e78c129eb7014c144cccb5b499cc8e1ff981d07 100644 |
--- a/impl/memory/datastore.go |
+++ b/impl/memory/datastore.go |
@@ -68,6 +68,10 @@ func (d *dsImpl) NewQuery(kind string) ds.Query { |
return &queryImpl{ns: d.ns, kind: kind} |
} |
+func (d *dsImpl) DecodeCursor(s string) (ds.Cursor, error) { |
+ return decodeCursor(s) |
+} |
+ |
func (d *dsImpl) Run(q ds.Query, cb ds.RawRunCB) error { |
rq := q.(*queryImpl) |
done, err := rq.valid(d.ns, true) |
@@ -141,6 +145,10 @@ func (d *txnDsImpl) DeleteMulti(keys []ds.Key, cb ds.DeleteMultiCB) error { |
}) |
} |
+func (d *txnDsImpl) DecodeCursor(s string) (ds.Cursor, error) { |
+ return decodeCursor(s) |
+} |
+ |
func (d *txnDsImpl) Run(q ds.Query, cb ds.RawRunCB) error { |
rq := q.(*queryImpl) |
done, err := rq.valid(d.ns, true) |