Method Read

go/fory/optional_serializer.go:256–306

(ctx *ReadContext, refMode RefMode, readType bool, hasGenerics bool, value reflect.Value)

}

func (s *optionalSerializer) Read(ctx *ReadContext, refMode RefMode, readType bool, hasGenerics bool, value reflect.Value) {
	buf := ctx.Buffer()
	switch refMode {
	case RefModeTracking:
		refID, refErr := ctx.RefResolver().TryPreserveRefId(buf)
		if refErr != nil {
			ctx.SetError(FromError(refErr))
			return
		}
		if refID < int32(NotNullValueFlag) {
			if refID == int32(NullFlag) {
				s.setHas(value, false)
				return
			}
			refObj := ctx.RefResolver().GetReadObject(refID)
			if refObj.IsValid() {
				valueField := s.valueField(value)
				if refObj.Type().AssignableTo(valueField.Type()) {
					valueField.Set(refObj)
					s.setHas(value, true)
					return
				}
			}
		}
	case RefModeNullOnly:
		flag := buf.ReadInt8(ctx.Err())
		if flag == NullFlag {
			s.setHas(value, false)
			return
		}
	case RefModeNone:
		// No null flag.
	}
	if readType {
		typeID := uint32(buf.ReadUint8(ctx.Err()))
		if ctx.HasError() {
			return
		}
		internalTypeID := TypeId(typeID)
		if IsNamespacedType(internalTypeID) || internalTypeID == COMPATIBLE_STRUCT || internalTypeID == STRUCT {
			typeInfo := ctx.TypeResolver().readTypeInfoWithTypeID(buf, typeID, ctx.Err())
			if structSer, ok := typeInfo.Serializer.(*structSerializer); ok && len(structSer.fieldDefs) > 0 {
				valueField := s.valueField(value)
				s.setHas(value, true)
				structSer.ReadData(ctx, valueField)
				return
			}
		}
	}
	s.ReadData(ctx, value)
}

func (s *optionalSerializer) ReadData(ctx *ReadContext, value reflect.Value) {
	valueField := s.valueField(value)