in internal/proto/setwatches.go [47:114]
func (r *SetWatches) Read(dec jute.Decoder) (err error) {
var size int
if err = dec.ReadStart(); err != nil {
return err
}
r.RelativeZxid, err = dec.ReadLong()
if err != nil {
return err
}
size, err = dec.ReadVectorStart()
if err != nil {
return err
}
if size < 0 {
r.DataWatches = nil
} else {
r.DataWatches = make([]string, size)
for i := 0; i < size; i++ {
r.DataWatches[i], err = dec.ReadString()
if err != nil {
return err
}
}
}
if err = dec.ReadVectorEnd(); err != nil {
return err
}
size, err = dec.ReadVectorStart()
if err != nil {
return err
}
if size < 0 {
r.ExistWatches = nil
} else {
r.ExistWatches = make([]string, size)
for i := 0; i < size; i++ {
r.ExistWatches[i], err = dec.ReadString()
if err != nil {
return err
}
}
}
if err = dec.ReadVectorEnd(); err != nil {
return err
}
size, err = dec.ReadVectorStart()
if err != nil {
return err
}
if size < 0 {
r.ChildWatches = nil
} else {
r.ChildWatches = make([]string, size)
for i := 0; i < size; i++ {
r.ChildWatches[i], err = dec.ReadString()
if err != nil {
return err
}
}
}
if err = dec.ReadVectorEnd(); err != nil {
return err
}
if err = dec.ReadEnd(); err != nil {
return err
}
return nil
}