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

Expose stream length. Clean up entry stream

Browse Source
This commit is contained in:
Adam Hathcock
2018-04-26 09:46:01 +01:00
parent b960f2e5ba
commit bee7f43880
2 changed files with 16 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@@ -15,3 +15,4 @@ tests/TestArchives/Scratch
tools
.vscode
.idea/
.DS_Store

33
src/SharpCompress/Common/EntryStream.cs
View File

@@ -6,15 +6,15 @@ namespace SharpCompress.Common
{
public class EntryStream : Stream
{
public IReader Reader { get; }
private readonly Stream stream;
private bool completed;
private bool isDisposed;
private readonly IReader _reader;
private readonly Stream _stream;
private bool _completed;
private bool _isDisposed;
internal EntryStream(IReader reader, Stream stream)
{
Reader = reader;
this.stream = stream;
_reader = reader;
_stream = stream;
}
/// <summary>
@@ -22,26 +22,23 @@ namespace SharpCompress.Common
/// </summary>
public void SkipEntry()
{
var buffer = new byte[4096];
while (Read(buffer, 0, buffer.Length) > 0)
{
}
completed = true;
this.Skip();
_completed = true;
}
protected override void Dispose(bool disposing)
{
if (!(completed || Reader.Cancelled))
if (!(_completed || _reader.Cancelled))
{
SkipEntry();
}
if (isDisposed)
if (_isDisposed)
{
return;
}
isDisposed = true;
_isDisposed = true;
base.Dispose(disposing);
stream.Dispose();
_stream.Dispose();
}
public override bool CanRead => true;
@@ -55,16 +52,16 @@ namespace SharpCompress.Common
throw new NotSupportedException();
}
public override long Length => throw new NotSupportedException();
public override long Length => _stream.Length;
public override long Position { get => throw new NotSupportedException(); set => throw new NotSupportedException(); }
public override int Read(byte[] buffer, int offset, int count)
{
int read = stream.Read(buffer, offset, count);
int read = _stream.Read(buffer, offset, count);
if (read <= 0)
{
completed = true;
_completed = true;
}
return read;
}