// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.
 
using System.IO.Pipelines;
using Microsoft.Extensions.Logging;
 
namespace Microsoft.AspNetCore.Server.Kestrel.Core.Internal;
 
internal sealed class LoggingDuplexPipe : DuplexPipeStreamAdapter<LoggingStream>
{
    private static readonly StreamPipeReaderOptions _defaultReaderOptions = new(useZeroByteReads: true);
    private static readonly StreamPipeWriterOptions _defaultWriterOptions = new();
 
    public LoggingDuplexPipe(IDuplexPipe transport, ILogger logger) :
        base(transport, _defaultReaderOptions, _defaultWriterOptions, stream => new LoggingStream(stream, logger))
    {
    }
}