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

AsyncStream for BZip2

Browse Source
This commit is contained in:
Adam Hathcock
2021-02-13 18:09:58 +00:00
parent ea688e1f4c
commit 15209178ce
1 changed files with 11 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
src/SharpCompress/Compressors/BZip2/BZip2Stream.cs
View File

@@ -3,10 +3,11 @@ using System.Buffers;
using System.IO;
using System.Threading;
using System.Threading.Tasks;
using SharpCompress.IO;
namespace SharpCompress.Compressors.BZip2
{
public sealed class BZip2Stream : Stream
public sealed class BZip2Stream : AsyncStream
{
private readonly Stream stream;
private bool isDisposed;
@@ -36,17 +37,14 @@ namespace SharpCompress.Compressors.BZip2
(stream as CBZip2OutputStream)?.Finish();
}
protected override void Dispose(bool disposing)
public override async ValueTask DisposeAsync()
{
if (isDisposed)
{
return;
}
isDisposed = true;
if (disposing)
{
stream.Dispose();
}
await stream.DisposeAsync();
}
public CompressionMode Mode { get; }
@@ -57,30 +55,20 @@ namespace SharpCompress.Compressors.BZip2
public override bool CanWrite => stream.CanWrite;
public override void Flush()
public override Task FlushAsync(CancellationToken cancellationToken)
{
stream.Flush();
return stream.FlushAsync(cancellationToken);
}
public override long Length => stream.Length;
public override long Position { get => stream.Position; set => stream.Position = value; }
public override int Read(byte[] buffer, int offset, int count)
{
throw new NotImplementedException();
}
public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
{
return stream.ReadAsync(buffer, cancellationToken);
}
public override int ReadByte()
{
throw new NotImplementedException();
}
public override long Seek(long offset, SeekOrigin origin)
{
return stream.Seek(offset, origin);
@@ -91,21 +79,16 @@ namespace SharpCompress.Compressors.BZip2
stream.SetLength(value);
}
public override Task WriteAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)
{
return stream.WriteAsync(buffer, offset, count, cancellationToken);
}
public override ValueTask WriteAsync(ReadOnlyMemory<byte> buffer, CancellationToken cancellationToken = new CancellationToken())
{
return stream.WriteAsync(buffer, cancellationToken);
}
public override void Write(byte[] buffer, int offset, int count)
{
throw new NotImplementedException();
}
public override void WriteByte(byte value)
{
throw new NotImplementedException();
}
/// <summary>
/// Consumes two bytes to test if there is a BZip2 header
/// </summary>