Function loadValue

protocol/prototest/reflect.go:41–68

(v reflect.Value)

}

func loadValue(v reflect.Value) (reset func()) {
	resets := []func(){}

	forEachField(v, func(f reflect.Value) {
		switch x := f.Interface().(type) {
		case protocol.RecordReader:
			records := loadRecords(x)
			resetFunc := func() {
				f.Set(reflect.ValueOf(protocol.NewRecordReader(makeRecords(records)...)))
			}
			resetFunc()
			resets = append(resets, resetFunc)
		case io.Reader:
			buf, _ := io.ReadAll(x)
			resetFunc := func() {
				f.Set(reflect.ValueOf(bytes.NewBuffer(buf)))
			}
			resetFunc()
			resets = append(resets, resetFunc)
		}
	})

	return func() {
		for _, f := range resets {
			f()
		}
	}
}

func forEachField(v reflect.Value, do func(reflect.Value)) {
	for v.Kind() == reflect.Ptr {