Method ReadData

go/fory/union.go:229–280

ReadData deserializes union payload (case_id + case_value).

(ctx *ReadContext, value reflect.Value)

// ReadData deserializes union payload (case_id + case_value).
func (s *UnionSerializer) ReadData(ctx *ReadContext, value reflect.Value) {
	if ctx.HasError() {
		return
	}
	if err := s.initialize(ctx.TypeResolver()); err != nil {
		ctx.SetError(DeserializationErrorf("union serializer init failed: %v", err))
		return
	}
	err := ctx.Err()
	caseID := ctx.Buffer().ReadVarUint32(err)
	if ctx.HasError() {
		return
	}
	info, ok := s.caseByID[caseID]
	if !ok {
		SkipAnyValue(ctx, true)
		if ctx.HasError() {
			return
		}
		ctx.SetError(DeserializationErrorf("unknown union case id: %d", caseID))
		return
	}

	var caseValue any
	if info.declaredValue {
		val, ok := readUnionDeclaredValue(ctx, info)
		if !ok {
			return
		}
		caseValue = val
	} else if info.needsOverride {
		val, ok := readUnionOverrideValue(ctx, info)
		if !ok {
			return
		}
		caseValue = val
	} else {
		v := reflect.New(info.type_).Elem()
		ctx.ReadValue(v, RefModeTracking, true)
		if ctx.HasError() {
			return
		}
		caseValue = v.Interface()
	}

	setter, setterErr := getUnionSetter(value)
	if setterErr != nil {
		ctx.SetError(DeserializationErrorf("union setter access failed: %v", setterErr))
		return
	}
	setter.ForyUnionSet(caseID, caseValue)
}

// ReadWithTypeInfo deserializes with pre-read type info.
func (s *UnionSerializer) ReadWithTypeInfo(ctx *ReadContext, refMode RefMode, typeInfo *TypeInfo, value reflect.Value) {