1package ndr 2 3import ( 4 "fmt" 5 "reflect" 6) 7 8func (dec *Decoder) fillPipe(v reflect.Value, tag reflect.StructTag) error { 9 s, err := dec.readUint32() // read element count of first chunk 10 if err != nil { 11 return err 12 } 13 a := reflect.MakeSlice(v.Type(), 0, 0) 14 c := reflect.MakeSlice(v.Type(), int(s), int(s)) 15 for s != 0 { 16 for i := 0; i < int(s); i++ { 17 err := dec.fill(c.Index(i), tag, &[]deferedPtr{}) 18 if err != nil { 19 return fmt.Errorf("could not fill element %d of pipe: %v", i, err) 20 } 21 } 22 s, err = dec.readUint32() // read element count of first chunk 23 if err != nil { 24 return err 25 } 26 a = reflect.AppendSlice(a, c) 27 c = reflect.MakeSlice(v.Type(), int(s), int(s)) 28 } 29 v.Set(a) 30 return nil 31} 32