fix: unwatch refactoring error

Tochemey · Sep 11, 2024 · 5ac03f8 · 5ac03f8
1 parent 7a457b7
commit 5ac03f8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/actors/pid.go b/actors/pid.go
@@ -990,7 +990,7 @@ func (pid *PID) Watch(cid *PID) {
 func (pid *PID) UnWatch(cid *PID) {
 	for _, item := range cid.watchers().Items() {
 		w := item.Value
-		if w.WatcherID.Equals(cid) {
+		if w.WatcherID.Equals(pid) {
 			w.Done <- types.Unit{}
 			pid.watchees().delete(cid.Address())
 			cid.watchers().Delete(item.Index)