// 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;
 
#nullable enable
 
namespace Microsoft.AspNetCore.Connections;
 
internal sealed class CompletionPipeReader : PipeReader
{
    private readonly PipeReader _inner;
 
    public bool IsCompleted { get; private set; }
    public Exception? CompleteException { get; private set; }
    public bool IsCompletedSuccessfully => IsCompleted && CompleteException == null;
 
    public CompletionPipeReader(PipeReader inner)
    {
        _inner = inner;
    }
 
    public override void AdvanceTo(SequencePosition consumed)
    {
        _inner.AdvanceTo(consumed);
    }
 
    public override void AdvanceTo(SequencePosition consumed, SequencePosition examined)
    {
        _inner.AdvanceTo(consumed, examined);
    }
 
    public override ValueTask CompleteAsync(Exception? exception = null)
    {
        IsCompleted = true;
        CompleteException = exception;
        return _inner.CompleteAsync(exception);
    }
 
    public override void Complete(Exception? exception = null)
    {
        IsCompleted = true;
        CompleteException = exception;
        _inner.Complete(exception);
    }
 
    public override void CancelPendingRead()
    {
        _inner.CancelPendingRead();
    }
 
    public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)
    {
        return _inner.ReadAsync(cancellationToken);
    }
 
    public override bool TryRead(out ReadResult result)
    {
        return _inner.TryRead(out result);
    }
 
    public void Reset()
    {
        IsCompleted = false;
        CompleteException = null;
    }
}