fix: invalidate local cache

xiaojiaoyu100 · Mar 26, 2020 · 69f2d7d · 69f2d7d
1 parent 858b381
commit 69f2d7d
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/freesia.go b/freesia.go
@@ -259,15 +259,13 @@ func (f *Freesia) Del(keys ...string) error {
 	if err != nil {
 		return err
 	}
-	for _, key := range keys {
-		if err := f.cache.Del(key); err != nil {
-			return err
-		}
+	if err := f.pub(keys...); err != nil {
+		return err
 	}
 	return nil
 }
 
-func (f *Freesia) Pub(keys ...string) error {
+func (f *Freesia) pub(keys ...string) error {
 	b, err := msgpack.Marshal(keys)
 	if err != nil {
 		return err