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

fix RarStream

Browse Source
This commit is contained in:
Adam Hathcock
2025-10-29 09:00:23 +00:00
parent b354f7a3a5
commit df2ed1e584
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/SharpCompress/Compressors/Rar/RarStream.cs
View File

@@ -149,6 +149,14 @@ internal class RarStream : Stream, IStreamStack
int offset,
int count,
System.Threading.CancellationToken cancellationToken
) =>
await ReadImplAsync(buffer, offset, count, cancellationToken).ConfigureAwait(false);
private async System.Threading.Tasks.Task<int> ReadImplAsync(
byte[] buffer,
int offset,
int count,
System.Threading.CancellationToken cancellationToken
)
{
outTotal = 0;
@@ -183,7 +191,7 @@ internal class RarStream : Stream, IStreamStack
}
#if NETCOREAPP2_1_OR_GREATER || NETSTANDARD2_1_OR_GREATER
public override System.Threading.Tasks.ValueTask<int> ReadAsync(
public override async System.Threading.Tasks.ValueTask<int> ReadAsync(
Memory<byte> buffer,
System.Threading.CancellationToken cancellationToken = default
)
@@ -192,9 +200,9 @@ internal class RarStream : Stream, IStreamStack
var array = System.Buffers.ArrayPool<byte>.Shared.Rent(buffer.Length);
try
{
var bytesRead = Read(array, 0, buffer.Length);
var bytesRead =await ReadImplAsync(array, 0, buffer.Length, cancellationToken).ConfigureAwait(false);
new ReadOnlySpan<byte>(array, 0, bytesRead).CopyTo(buffer.Span);
return new System.Threading.Tasks.ValueTask<int>(bytesRead);
return bytesRead;
}
finally
{