Method ReadData

go/fory/array.go:227–270

(ctx *ReadContext, value reflect.Value)

}

func (s *arrayConcreteValueSerializer) ReadData(ctx *ReadContext, value reflect.Value) {
	buf := ctx.Buffer()
	err := ctx.Err()
	length := int(buf.ReadVarUint32(err))
	if ctx.HasError() {
		return
	}
	if length != value.Len() {
		ctx.SetError(DeserializationErrorf("array length %d does not match serialized length %d", value.Len(), length))
		return
	}

	var trackRefs bool
	if length > 0 {
		// Read collection flags (same format as slices)
		collectFlag := buf.ReadInt8(err)
		if ctx.HasError() {
			return
		}

		// Read element type info if present
		if (collectFlag & CollectionIsSameType) != 0 {
			if (collectFlag & CollectionIsDeclElementType) == 0 {
				ctx.TypeResolver().ReadTypeInfo(buf, err)
			}
		}

		trackRefs = (collectFlag & CollectionTrackingRef) != 0
	}

	for i := 0; i < length && i < value.Len(); i++ {
		elem := value.Index(i)

		// When tracking refs, the element serializer handles ref flags
		if trackRefs {
			s.elemSerializer.Read(ctx, RefModeTracking, false, false, elem)
		} else {
			s.elemSerializer.ReadData(ctx, elem)
		}
		if ctx.HasError() {
			return
		}
	}
}

func (s *arrayConcreteValueSerializer) Read(ctx *ReadContext, refMode RefMode, readType bool, hasGenerics bool, value reflect.Value) {
	done := readArrayRefAndType(ctx, refMode, readType, value)