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

fixed read only sub stream

Browse Source
This commit is contained in:
Adam Hathcock
2021-02-21 13:37:58 +00:00
parent 5cfc608010
commit dd710ec308
1 changed files with 25 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/SharpCompress/IO/ReadOnlySubStream.cs
View File

@@ -34,12 +34,37 @@ namespace SharpCompress.IO
public override long Position { get => throw new NotSupportedException(); set => throw new NotSupportedException(); }
public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
{
var count = buffer.Length;
if (BytesLeftToRead < count)
{
count = (int)BytesLeftToRead;
}
if (count == 0)
{
return 0;
}
int read = await Stream.ReadAsync(buffer.Slice(0, count), cancellationToken);
if (read > 0)
{
BytesLeftToRead -= read;
}
return read;
}
public override async Task<int> ReadAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)
{
if (BytesLeftToRead < count)
{
count = (int)BytesLeftToRead;
}
if (count == 0)
{
return 0;
}
int read = await Stream.ReadAsync(buffer, offset, count, cancellationToken);
if (read > 0)
{