WriteStreamAsync< TValue >()

static async Task System.Text.Json.JsonSerializer.WriteStreamAsync< TValue > ( Stream utf8Json, TValue value, JsonTypeInfo jsonTypeInfo, CancellationToken cancellationToken )

inlinestaticprivate

Definition at line 1748 of file JsonSerializer.cs.

    {
        JsonSerializerOptions options = jsonTypeInfo.Options;
        JsonWriterOptions writerOptions = options.GetWriterOptions();
        using PooledByteBufferWriter bufferWriter = new PooledByteBufferWriter(options.DefaultBufferSize);
        using Utf8JsonWriter writer = new Utf8JsonWriter(bufferWriter, writerOptions);
        WriteStack state = new WriteStack
        {
            CancellationToken = cancellationToken
        };
        JsonConverter converter = state.Initialize(jsonTypeInfo, supportContinuation: true);
        try
        {
            bool isFinalBlock;
            do
            {
                state.FlushThreshold = (int)((float)bufferWriter.Capacity * 0.9f);
                try
                {
                    isFinalBlock = WriteCore(converter, writer, in value, options, ref state);
                    if (state.SuppressFlush)
                    {
                        state.SuppressFlush = false;
                        continue;
                    }
                    await bufferWriter.WriteToStreamAsync(utf8Json, cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
                    bufferWriter.Clear();
                }
                finally
                {
                    if (state.PendingTask != null)
                    {
                        try
                        {
                            await state.PendingTask.ConfigureAwait(continueOnCapturedContext: false);
                        }
                        catch
                        {
                        }
                    }
                    List<IAsyncDisposable> completedAsyncDisposables = state.CompletedAsyncDisposables;
                    if (completedAsyncDisposables != null && completedAsyncDisposables.Count > 0)
                    {
                        await state.DisposeCompletedAsyncDisposables().ConfigureAwait(continueOnCapturedContext: false);
                    }
                }
            }
            while (!isFinalBlock);
        }
        catch
        {
            await state.DisposePendingDisposablesOnExceptionAsync().ConfigureAwait(continueOnCapturedContext: false);
            throw;
        }
    }

References System.cancellationToken, System.Collections.Generic.Dictionary< TKey, TValue >.Clear(), System.converter, System.Collections.Generic.Dictionary< TKey, TValue >.Count, System.Text.Json.Dictionary, System.Text.Json.Serialization.JsonConverter< T >.Initialize(), System.options, System.state, System.value, and System.writer.