starred/sharpcompress
1
0
Fork 0
mirror of https://github.com/adamhathcock/sharpcompress.git synced 2026-09-22 15:04:43 +00:00
Code Issues 975 Packages Projects Releases 25 Wiki Activity

tests for normal and forward only usage

Browse Source
This commit is contained in:
Adam Hathcock
2026-07-27 15:59:36 +01:00
parent 6062623dd8
commit 1f490d933f
1 changed files with 58 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

58
tests/SharpCompress.Test/Zip/ZipReaderAsyncTests.cs
View File

@@ -3,11 +3,13 @@ using System.IO;
using System.Threading;
using System.Threading.Tasks;
using SharpCompress.Archives;
using SharpCompress.Archives.Zip;
using SharpCompress.Common;
using SharpCompress.IO;
using SharpCompress.Readers;
using SharpCompress.Readers.Zip;
using SharpCompress.Test.Mocks;
using SharpCompress.Writers.Zip;
using Xunit;
namespace SharpCompress.Test.Zip;
@@ -16,6 +18,62 @@ public class ZipReaderAsyncTests : ReaderTests
{
public ZipReaderAsyncTests() => UseExtensionInsteadOfNameToVerify = true;
[Fact]
public async ValueTask ZipArchive_Created_Entry_Reports_Size_With_AsyncReader()
{
byte[] content = [1, 2, 3, 4, 5];
using var source = new MemoryStream(content);
using var archiveStream = new MemoryStream();
using (var archive = ZipArchive.CreateArchive())
{
archive.AddEntry("test.bin", source, source.Length);
archive.SaveTo(archiveStream, new ZipWriterOptions(CompressionType.Deflate));
}
archiveStream.Position = 0;
await using var reader = await ReaderFactory.OpenAsyncReader(
archiveStream,
ReaderOptions.ForExternalStream
);
Assert.True(await reader.MoveToNextEntryAsync());
Assert.Equal(content.Length, reader.Entry.Size);
using var extracted = new MemoryStream();
await reader.WriteEntryToAsync(extracted);
Assert.Equal(content, extracted.ToArray());
Assert.False(await reader.MoveToNextEntryAsync());
}
[Fact]
public async ValueTask ZipWriter_Created_Entry_Reports_Size_With_AsyncReader_ForwardOnly()
{
byte[] content = [1, 2, 3, 4, 5];
using var source = new ForwardOnlyStream(new MemoryStream(content));
using var destination = new MemoryStream();
using var archiveStream = new ForwardOnlyStream(destination);
using (
var writer = new ZipWriter(archiveStream, new ZipWriterOptions(CompressionType.Deflate))
)
{
writer.Write("test.bin", source, modificationTime: null);
}
destination.Position = 0;
await using var reader = await ReaderFactory.OpenAsyncReader(
destination,
ReaderOptions.ForExternalStream
);
Assert.True(await reader.MoveToNextEntryAsync());
Assert.Equal(0, reader.Entry.Size);
using var extracted = new MemoryStream();
await reader.WriteEntryToAsync(extracted);
Assert.Equal(content, extracted.ToArray());
Assert.False(await reader.MoveToNextEntryAsync());
}
[Fact]
public async ValueTask Issue_269_Double_Skip_Async()
{