diff --git a/zk/conn.go b/zk/conn.go index da9503a2..412e1407 100644 --- a/zk/conn.go +++ b/zk/conn.go @@ -884,8 +884,10 @@ func (c *Conn) recvLoop(conn net.Conn) error { switch res.Type { case EventNodeCreated: wTypes = append(wTypes, watchTypeExist) - case EventNodeDeleted, EventNodeDataChanged: + case EventNodeDeleted: wTypes = append(wTypes, watchTypeExist, watchTypeData, watchTypeChild) + case EventNodeDataChanged: + wTypes = append(wTypes, watchTypeData) case EventNodeChildrenChanged: wTypes = append(wTypes, watchTypeChild) }