Method ReadCollectionData

csharp/src/Fory/CollectionSerializers.cs:198–309

(Serializer<T> elementSerializer, ReadContext context)

    }

    public static List<T> ReadCollectionData<T>(Serializer<T> elementSerializer, ReadContext context)
    {
        TypeInfo elementTypeInfo = context.TypeResolver.GetTypeInfo<T>();
        int length = checked((int)context.Reader.ReadVarUInt32());
        if (length == 0)
        {
            return [];
        }

        byte header = context.Reader.ReadUInt8();
        // IMPORTANT: collection readers must obey the ref/null bits written on
        // the wire, not the local generic metadata that may imply a different
        // ref policy. Shared xlang tests intentionally deserialize one ref
        // policy and then serialize another local payload. DO NOT REMOVE this comment.
        bool trackRef = (header & CollectionBits.TrackingRef) != 0;
        bool hasNull = (header & CollectionBits.HasNull) != 0;
        bool declared = (header & CollectionBits.DeclaredElementType) != 0;
        bool sameType = (header & CollectionBits.SameType) != 0;
        context.Reader.CheckBound(length);
        List<T> values = new(length);
        if (!sameType)
        {
            if (trackRef)
            {
                for (int i = 0; i < length; i++)
                {
                    values.Add(elementSerializer.Read(context, RefMode.Tracking, true));
                }

                return values;
            }

            if (hasNull)
            {
                for (int i = 0; i < length; i++)
                {
                    sbyte refFlag = context.Reader.ReadInt8();
                    if (refFlag == (sbyte)RefFlag.Null)
                    {
                        values.Add((T)elementSerializer.DefaultObject!);
                    }
                    else if (refFlag == (sbyte)RefFlag.NotNullValue)
                    {
                        values.Add(elementSerializer.Read(context, RefMode.None, true));
                    }
                    else
                    {
                        throw new RefException($"invalid nullability flag {refFlag}");
                    }
                }
            }
            else
            {
                for (int i = 0; i < length; i++)
                {
                    values.Add(elementSerializer.Read(context, RefMode.None, true));
                }
            }