StackOrQueueConverter.cs

Go to the documentation of this file.

using System.Collections;
using System.Text.Json.Serialization.Metadata;
 
namespace System.Text.Json.Serialization.Converters;
 
internal class StackOrQueueConverter<TCollection> : JsonCollectionConverter<TCollection, object> where TCollection : IEnumerable
{
    protected sealed override void Add(in object value, ref ReadStack state)
    {
        Action<TCollection, object> action = (Action<TCollection, object>)state.Current.JsonTypeInfo.AddMethodDelegate;
        action((TCollection)state.Current.ReturnValue, value);
    }
 
    protected sealed override void CreateCollection(ref Utf8JsonReader reader, ref ReadStack state, JsonSerializerOptions options)
    {
        JsonTypeInfo jsonTypeInfo = state.Current.JsonTypeInfo;
        JsonTypeInfo.ConstructorDelegate createObject = jsonTypeInfo.CreateObject;
        if (createObject == null)
        {
            ThrowHelper.ThrowNotSupportedException_CannotPopulateCollection(TypeToConvert, ref reader, ref state);
        }
        state.Current.ReturnValue = createObject();
    }
 
    protected sealed override bool OnWriteResume(Utf8JsonWriter writer, TCollection value, JsonSerializerOptions options, ref WriteStack state)
    {
        IEnumerator enumerator;
        if (state.Current.CollectionEnumerator == null)
        {
            enumerator = value.GetEnumerator();
            if (!enumerator.MoveNext())
            {
                return true;
            }
        }
        else
        {
            enumerator = state.Current.CollectionEnumerator;
        }
        JsonConverter<object> elementConverter = JsonCollectionConverter<TCollection, object>.GetElementConverter(ref state);
        do
        {
            if (ShouldFlush(writer, ref state))
            {
                state.Current.CollectionEnumerator = enumerator;
                return false;
            }
            object value2 = enumerator.Current;
            if (!elementConverter.TryWrite(writer, in value2, options, ref state))
            {
                state.Current.CollectionEnumerator = enumerator;
                return false;
            }
        }
        while (enumerator.MoveNext());
        return true;
    }
}