Add initial set of conformance tests for Stream

src/libraries/Common/src/System/Net/StreamBuffer.cs

@@ -343,7 +343,6 @@ public void Reset()
             {
                 if (_hasWaiter != 0)
                 {
-                    Debug.Fail("Concurrent use is not supported");
                     throw new InvalidOperationException("Concurrent use is not supported");
                 }
 

src/libraries/Common/tests/Common.Tests.csproj

@@ -102,6 +102,12 @@
              Link="Common\System\Threading\Tasks\TaskToApm.cs" />
     <Compile Include="$(CoreLibSharedDir)System\IO\PathInternal.cs"
              Link="System\IO\PathInternal.cs" />
+    <Compile Include="System\IO\ConnectedStreams.cs" Link="System\IO\ConnectedStreams.cs" />
+    <Compile Include="Tests\System\IO\ConnectedStreamsTests.cs" />
+    <Compile Include="Tests\System\IO\StreamConformanceTests.cs" />
+    <Compile Include="$(CommonPath)System\Net\ArrayBuffer.cs" Link="Common\System\Net\ArrayBuffer.cs" />
+    <Compile Include="$(CommonPath)System\Net\StreamBuffer.cs" Link="Common\System\Net\StreamBuffer.cs" />
+    <Compile Include="$(CommonTestPath)System\IO\CallTrackingStream.cs" Link="Common\System\IO\CallTrackingStream.cs" />
   </ItemGroup>
   <ItemGroup Condition="'$(TargetsWindows)'=='true'">
     <Compile Include="$(CoreLibSharedDir)System\IO\PathInternal.Windows.cs"

src/libraries/Common/tests/System/IO/Compression/CompressionStreamTestBase.cs

@@ -2,10 +2,12 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 
 using System.Collections.Generic;
+using System.IO.Tests;
+using System.Threading.Tasks;
 
 namespace System.IO.Compression
 {
-    public abstract class CompressionTestBase
+    public abstract class CompressionTestBase : WrappingConnectedStreamConformanceTests
     {
         public static IEnumerable<object[]> UncompressedTestFiles()
         {
@@ -36,8 +38,22 @@ public abstract class CompressionStreamTestBase : CompressionTestBase
         public abstract Stream CreateStream(Stream stream, CompressionLevel level);
         public abstract Stream CreateStream(Stream stream, CompressionLevel level, bool leaveOpen);
         public abstract Stream BaseStream(Stream stream);
-        public virtual bool FlushCompletes { get => true; }
-        public virtual bool FlushNoOps { get => false; }
         public virtual int BufferSize { get => 8192; }
+
+        protected override Task<StreamPair> CreateConnectedStreamsAsync()
+        {
+            (Stream stream1, Stream stream2) = ConnectedStreams.CreateBidirectional(4 * 1024, 16 * 1024);
+            return Task.FromResult<StreamPair>((CreateStream(stream1, CompressionMode.Compress), CreateStream(stream2, CompressionMode.Decompress)));
+        }
+
+        protected override Task<StreamPair> CreateWrappedConnectedStreamsAsync(StreamPair wrapped, bool leaveOpen) =>
+            Task.FromResult<StreamPair>((CreateStream(wrapped.Stream1, CompressionMode.Compress, leaveOpen), CreateStream(wrapped.Stream2, CompressionMode.Decompress, leaveOpen)));
+
+        protected override int BufferedSize => 16 * 1024 + BufferSize;
+        protected override bool UsableAfterCanceledReads => false;
+        protected override Type UnsupportedReadWriteExceptionType => typeof(InvalidOperationException);
+        protected override bool WrappedUsableAfterClose => false;
+        protected override bool FlushRequiredToWriteData => true;
+        protected override bool FlushGuaranteesAllDataWritten => false;
     }
 }