| Index: impl/memory/datastore_data.go
|
| diff --git a/impl/memory/datastore_data.go b/impl/memory/datastore_data.go
|
| index 15ffc2f797c5cd5b6a45150c2177f9189e5e26d0..b0613e6defa409ea8f70fe6cc285e1fa5ad979fc 100644
|
| --- a/impl/memory/datastore_data.go
|
| +++ b/impl/memory/datastore_data.go
|
| @@ -283,9 +283,6 @@ func (d *dataStoreData) putMulti(keys []*ds.Key, vals []ds.PropertyMap, cb ds.Pu
|
| }()
|
| if cb != nil {
|
| if err := cb(k, err); err != nil {
|
| - if err == ds.Stop {
|
| - return nil
|
| - }
|
| return err
|
| }
|
| }
|
| @@ -358,9 +355,6 @@ func (d *dataStoreData) delMulti(keys []*ds.Key, cb ds.DeleteMultiCB) error {
|
| }()
|
| if cb != nil {
|
| if err := cb(err); err != nil {
|
| - if err == ds.Stop {
|
| - return nil
|
| - }
|
| return err
|
| }
|
| }
|
| @@ -368,9 +362,6 @@ func (d *dataStoreData) delMulti(keys []*ds.Key, cb ds.DeleteMultiCB) error {
|
| } else if cb != nil {
|
| for range keys {
|
| if err := cb(nil); err != nil {
|
| - if err == ds.Stop {
|
| - return nil
|
| - }
|
| return err
|
| }
|
| }
|
|
|