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