| Index: filter/txnBuf/txnbuf_test.go
|
| diff --git a/filter/txnBuf/txnbuf_test.go b/filter/txnBuf/txnbuf_test.go
|
| index 62ecba2d03d3a316a821d0327e2e357d4aac88bb..d027ed331f39fb669740434e3bbed0dc64b6874f 100644
|
| --- a/filter/txnBuf/txnbuf_test.go
|
| +++ b/filter/txnBuf/txnbuf_test.go
|
| @@ -856,20 +856,18 @@ func TestQuerySupport(t *testing.T) {
|
| ds := datastore.Get(c)
|
|
|
| q := datastore.NewQuery("Foo").Ancestor(root)
|
| - return ds.Run(q, func(pm datastore.PropertyMap, _ datastore.CursorCB) bool {
|
| + return ds.Run(q, func(pm datastore.PropertyMap) {
|
| So(ds.RunInTransaction(func(c context.Context) error {
|
| ds := datastore.Get(c)
|
| pm["Value"] = append(pm["Value"], datastore.MkProperty("wat"))
|
| return ds.Put(pm)
|
| }, nil), ShouldBeNil)
|
| - return true
|
| })
|
| }, &datastore.TransactionOptions{XG: true}), ShouldBeNil)
|
|
|
| - So(ds.Run(datastore.NewQuery("Foo"), func(pm datastore.PropertyMap, _ datastore.CursorCB) bool {
|
| + So(ds.Run(datastore.NewQuery("Foo"), func(pm datastore.PropertyMap) {
|
| val := pm["Value"]
|
| So(val[len(val)-1].Value(), ShouldResemble, "wat")
|
| - return true
|
| }), ShouldBeNil)
|
| })
|
|
|
|
|