src/SignalR/common/Shared/StreamExtensions.cs - main - githubmirror/aspnetcore

src/SignalR/common/Shared/StreamExtensions.cs

46 строк2 KB

Stephen Halter

.ConfigureAwait(false) in SignalR client libraries (#39728)

25 янв 2022, 23:54

25 янв 2022, 23:5498bb246

// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.

using System.Buffers;
using System.Diagnostics;
using System.Runtime.InteropServices;
using System.Threading;
using System.Threading.Tasks;

namespace System.IO;

internal static class StreamExtensions
{
    public static ValueTask WriteAsync(this Stream stream, ReadOnlySequence<byte> buffer, CancellationToken cancellationToken = default)
    {
        if (buffer.IsSingleSegment)
        {
#if NETCOREAPP || NETSTANDARD2_1
            return stream.WriteAsync(buffer.First, cancellationToken);
#else
            var isArray = MemoryMarshal.TryGetArray(buffer.First, out var arraySegment);
            // We're using the managed memory pool which is backed by managed buffers
            Debug.Assert(isArray);
            return new ValueTask(stream.WriteAsync(arraySegment.Array, arraySegment.Offset, arraySegment.Count, cancellationToken));
#endif
        }

        return WriteMultiSegmentAsync(stream, buffer, cancellationToken);
    }

    private static async ValueTask WriteMultiSegmentAsync(Stream stream, ReadOnlySequence<byte> buffer, CancellationToken cancellationToken)
    {
        var position = buffer.Start;
        while (buffer.TryGet(ref position, out var segment))
        {
#if NETCOREAPP || NETSTANDARD2_1
            await stream.WriteAsync(segment, cancellationToken).ConfigureAwait(false);
#else
            var isArray = MemoryMarshal.TryGetArray(segment, out var arraySegment);
            // We're using the managed memory pool which is backed by managed buffers
            Debug.Assert(isArray);
            await stream.WriteAsync(arraySegment.Array, arraySegment.Offset, arraySegment.Count, cancellationToken).ConfigureAwait(false);
#endif
        }
    }
}