Enable parallel test execution

src/SharpCompress/Archives/ArchiveFactory.cs

@@ -92,7 +92,7 @@ public static IWritableArchive Create(ArchiveType type)
         public static IArchive Open(string filePath, ReaderOptions options = null)
         {
             filePath.CheckNotNullOrEmpty("filePath");
-            return Open(new FileInfo(filePath), options ?? new ReaderOptions());
+            return Open(new FileInfo(filePath), options);
         }
 
         /// <summary>
@@ -103,36 +103,31 @@ public static IArchive Open(string filePath, ReaderOptions options = null)
         public static IArchive Open(FileInfo fileInfo, ReaderOptions options = null)
         {
             fileInfo.CheckNotNull("fileInfo");
-            options = options ?? new ReaderOptions();
+            options = options ?? new ReaderOptions { LeaveStreamOpen = false };
             using (var stream = fileInfo.OpenRead())
             {
                 if (ZipArchive.IsZipFile(stream, null))
                 {
-                    stream.Dispose();
                     return ZipArchive.Open(fileInfo, options);
                 }
                 stream.Seek(0, SeekOrigin.Begin);
                 if (SevenZipArchive.IsSevenZipFile(stream))
                 {
-                    stream.Dispose();
                     return SevenZipArchive.Open(fileInfo, options);
                 }
                 stream.Seek(0, SeekOrigin.Begin);
                 if (GZipArchive.IsGZipFile(stream))
                 {
-                    stream.Dispose();
                     return GZipArchive.Open(fileInfo, options);
                 }
                 stream.Seek(0, SeekOrigin.Begin);
                 if (RarArchive.IsRarFile(stream, options))
                 {
-                   stream.Dispose();
                    return RarArchive.Open(fileInfo, options);
                 }
                 stream.Seek(0, SeekOrigin.Begin);
                 if (TarArchive.IsTarFile(stream))
                 {
-                    stream.Dispose();
                     return TarArchive.Open(fileInfo, options);
                 }
                 throw new InvalidOperationException("Cannot determine compressed stream type. Supported Archive Formats: Zip, GZip, Tar, Rar, 7Zip");

src/SharpCompress/Common/Tar/TarReadOnlySubStream.cs

@@ -1,16 +1,16 @@
-using System;
+using SharpCompress.IO;
+using System;
 using System.IO;
 
 namespace SharpCompress.Common.Tar
 {
-    internal class TarReadOnlySubStream : Stream
+    internal class TarReadOnlySubStream : NonDisposingStream
     {
         private bool _isDisposed;
         private long _amountRead;
 
-        public TarReadOnlySubStream(Stream stream, long bytesToRead)
+        public TarReadOnlySubStream(Stream stream, long bytesToRead) : base(stream, throwOnDispose: false)
         {
-            Stream = stream;
             BytesLeftToRead = bytesToRead;
         }
 
@@ -36,12 +36,11 @@ protected override void Dispose(bool disposing)
                 var buffer = new byte[skipBytes];
                 Stream.ReadFully(buffer);
             }
+            base.Dispose(disposing);
         }
 
         private long BytesLeftToRead { get; set; }
 
-        public Stream Stream { get; }
-
         public override bool CanRead => true;
 
         public override bool CanSeek => false;

src/SharpCompress/Common/Volume.cs

@@ -1,4 +1,5 @@
-using System.IO;
+using System;
+using System.IO;
 using SharpCompress.IO;
 using SharpCompress.Readers;
 
@@ -33,15 +34,18 @@ internal Volume(Stream stream, ReaderOptions readerOptions)
         /// </summary>
         public virtual bool IsMultiVolume => true;
 
-        private bool _disposed;
-
-        public void Dispose()
+        protected virtual void Dispose(bool disposing)
         {
-            if (!_disposed)
+            if (disposing)
             {
                 _actualStream.Dispose();
-                _disposed = true;
             }
         }
+
+        public void Dispose()
+        {
+            Dispose(true);
+            GC.SuppressFinalize(this);
+        }
     }
 }

src/SharpCompress/IO/BufferedSubStream.cs

@@ -3,33 +3,22 @@
 
 namespace SharpCompress.IO
 {
-    internal class BufferedSubStream : Stream
+    internal class BufferedSubStream : NonDisposingStream
     {
         private long position;
         private int cacheOffset;
         private int cacheLength;
         private readonly byte[] cache;
 
-        public BufferedSubStream(Stream stream, long origin, long bytesToRead)
+        public BufferedSubStream(Stream stream, long origin, long bytesToRead) : base(stream, throwOnDispose: false)
         {
-            Stream = stream;
             position = origin;
             BytesLeftToRead = bytesToRead;
             cache = new byte[32 << 10];
         }
 
-        protected override void Dispose(bool disposing)
-        {
-            if (disposing)
-            {
-                //Stream.Dispose();
-            }
-        }
-
         private long BytesLeftToRead { get; set; }
 
-        public Stream Stream { get; }
-
         public override bool CanRead => true;
 
         public override bool CanSeek => false;

src/SharpCompress/IO/CountingWritableSubStream.cs

@@ -3,13 +3,10 @@
 
 namespace SharpCompress.IO
 {
-    internal class CountingWritableSubStream : Stream
+    internal class CountingWritableSubStream : NonDisposingStream
     {
-        private readonly Stream writableStream;
-
-        internal CountingWritableSubStream(Stream stream)
+        internal CountingWritableSubStream(Stream stream) : base(stream, throwOnDispose: false)
         {
-            writableStream = stream;
         }
 
         public ulong Count { get; private set; }
@@ -22,7 +19,7 @@ internal CountingWritableSubStream(Stream stream)
 
         public override void Flush()
         {
-            writableStream.Flush();
+            Stream.Flush();
         }
 
         public override long Length => throw new NotSupportedException();
@@ -46,13 +43,13 @@ public override void SetLength(long value)
 
         public override void Write(byte[] buffer, int offset, int count)
         {
-            writableStream.Write(buffer, offset, count);
+            Stream.Write(buffer, offset, count);
             Count += (uint)count;
         }
 
         public override void WriteByte(byte value)
         {
-            writableStream.WriteByte(value);
+            Stream.WriteByte(value);
             ++Count;
         }
     }

src/SharpCompress/IO/ListeningStream.cs

@@ -20,6 +20,7 @@ protected override void Dispose(bool disposing)
             {
                 Stream.Dispose();
             }
+            base.Dispose(disposing);
         }
 
         public Stream Stream { get; }
@@ -74,10 +75,5 @@ public override void Write(byte[] buffer, int offset, int count)
         {
             Stream.Write(buffer, offset, count);
         }
-
-        public override void WriteByte(byte value)
-        {
-            Stream.WriteByte(value);
-        }
     }
 }

src/SharpCompress/IO/NonDisposingStream.cs

@@ -15,10 +15,9 @@ public NonDisposingStream(Stream stream, bool throwOnDispose = false)
 
         protected override void Dispose(bool disposing)
         {
-            GC.SuppressFinalize(this);
             if (ThrowOnDispose)
             {
-                throw new InvalidOperationException();
+                throw new InvalidOperationException($"Attempt to dispose of a {nameof(NonDisposingStream)} when {nameof(ThrowOnDispose)} is {ThrowOnDispose}");
             }
         }
 
@@ -44,11 +43,6 @@ public override int Read(byte[] buffer, int offset, int count)
             return Stream.Read(buffer, offset, count);
         }
 
-        public override int ReadByte()
-        {
-            return Stream.ReadByte();
-        }
-
         public override long Seek(long offset, SeekOrigin origin)
         {
             return Stream.Seek(offset, origin);
@@ -63,10 +57,5 @@ public override void Write(byte[] buffer, int offset, int count)
         {
             Stream.Write(buffer, offset, count);
         }
-
-        public override void WriteByte(byte value)
-        {
-            Stream.WriteByte(value);
-        }
     }
 }

src/SharpCompress/IO/ReadOnlySubStream.cs

@@ -11,7 +11,7 @@ public ReadOnlySubStream(Stream stream, long bytesToRead)
         }
 
         public ReadOnlySubStream(Stream stream, long? origin, long bytesToRead)
-            : base(stream, false)
+            : base(stream, throwOnDispose: false)
         {
             if (origin != null)
             {