This commit is contained in:
Adam Hathcock
2026-05-28 09:22:25 +01:00
parent 3530dd9d68
commit d61b5cde2b
5 changed files with 7 additions and 17 deletions

View File

@@ -75,9 +75,7 @@ internal sealed class TarFilePart : FilePart
if (_seekableStream != null)
{
_seekableStream.Position = Header.DataStartPosition ?? 0;
return new ValueTask<Stream?>(
new TarReadOnlySubStream(_seekableStream, Header.Size)
);
return new ValueTask<Stream?>(new TarReadOnlySubStream(_seekableStream, Header.Size));
}
return new ValueTask<Stream?>(Header.PackedStream.NotNull());
}

View File

@@ -44,10 +44,7 @@ internal static partial class TarHeaderFactory
break;
case StreamingMode.Streaming:
{
header.PackedStream = new TarReadOnlySubStream(
stream,
header.Size
);
header.PackedStream = new TarReadOnlySubStream(stream, header.Size);
}
break;
default:

View File

@@ -38,10 +38,7 @@ internal static partial class TarHeaderFactory
break;
case StreamingMode.Streaming:
{
header.PackedStream = new TarReadOnlySubStream(
stream,
header.Size
);
header.PackedStream = new TarReadOnlySubStream(stream, header.Size);
}
break;
default:

View File

@@ -10,6 +10,7 @@ namespace SharpCompress.Common.Zip;
internal partial class SeekableZipFilePart : IDisposable
{
private readonly SemaphoreSlim _asyncHeaderSemaphore = new(1, 1);
internal override async ValueTask<Stream?> GetCompressedStreamAsync(
CancellationToken cancellationToken = default
)
@@ -75,10 +76,9 @@ internal partial class SeekableZipFilePart : IDisposable
try
{
Header = await _headerFactory.GetLocalHeaderAsync(
streamToUse,
(DirectoryEntryHeader)Header
).ConfigureAwait(false);
Header = await _headerFactory
.GetLocalHeaderAsync(streamToUse, (DirectoryEntryHeader)Header)
.ConfigureAwait(false);
}
finally
{
@@ -99,5 +99,4 @@ internal partial class SeekableZipFilePart : IDisposable
}
public void Dispose() => _asyncHeaderSemaphore.Dispose();
}

View File

@@ -88,7 +88,6 @@ internal partial class SeekableZipFilePart : ZipFilePart
}
}
protected override Stream CreateBaseStream()
{
// If BaseStream is a SourceStream in file mode with multi-threading enabled,