Function closeMessage

protocol/prototest/reflect.go:17–35

(m protocol.Message)

)

func closeMessage(m protocol.Message) {
	forEachField(reflect.ValueOf(m), func(v reflect.Value) {
		if v.Type().Implements(recordReader) {
			rr := v.Interface().(protocol.RecordReader)
			for {
				r, err := rr.ReadRecord()
				if err != nil {
					break
				}
				if r.Key != nil {
					r.Key.Close()
				}
				if r.Value != nil {
					r.Value.Close()
				}
			}
		}
	})
}

func load(v interface{}) (reset func()) {
	return loadValue(reflect.ValueOf(v))