sharpcompress/tests/SharpCompress.Test/Mocks/FlushOnDisposeStream.cs

using System;
using System.IO;
using System.Threading.Tasks;

namespace SharpCompress.Test.Mocks;

// This is a simplified version of CryptoStream that always flushes the inner stream on Dispose to trigger an error in EntryStream
// CryptoStream doesn't always trigger the Flush, so this class is used instead
// See https://referencesource.microsoft.com/#mscorlib/system/security/cryptography/cryptostream.cs,141

public class FlushOnDisposeStream(Stream innerStream) : Stream
{
    public override bool CanRead => innerStream.CanRead;

    public override bool CanSeek => false;

    public override bool CanWrite => false;

    public override long Length => innerStream.Length;

    public override long Position
    {
        get => innerStream.Position;
        set => innerStream.Position = value;
    }

    public override void Flush() { }

    public override int Read(byte[] buffer, int offset, int count) =>
        innerStream.Read(buffer, offset, count);

    public override long Seek(long offset, SeekOrigin origin) =>
        throw new NotImplementedException();

    public override void SetLength(long value) => throw new NotImplementedException();

    public override void Write(byte[] buffer, int offset, int count) =>
        throw new NotImplementedException();

    protected override void Dispose(bool disposing)
    {
        if (disposing)
        {
            innerStream.Flush();
            innerStream.Close();
        }

        base.Dispose(disposing);
    }

#if !LEGACY_DOTNET
    public override async ValueTask DisposeAsync()
    {
        await innerStream.FlushAsync();
        innerStream.Close();
        await base.DisposeAsync();
    }
#endif
}