src: Implement the missing async methods in internal helper stream classes.

Author: carlossanlop

src/libraries/System.IO.Compression/src/System/IO/Compression/PositionPreservingWriteOnlyStreamWrapper.cs

@@ -93,6 +93,8 @@ protected override void Dispose(bool disposing)
                 _stream.Dispose();
         }
 
+        public override ValueTask DisposeAsync() => _stream.DisposeAsync();
+
         public override long Length
         {
             get { throw new NotSupportedException(SR.NotSupported); }
@@ -108,9 +110,10 @@ public override void SetLength(long value)
             throw new NotSupportedException(SR.NotSupported);
         }
 
-        public override int Read(byte[] buffer, int offset, int count)
-        {
-            throw new NotSupportedException(SR.NotSupported);
-        }
+        public override int Read(byte[] buffer, int offset, int count) => throw new NotSupportedException(SR.NotSupported);
+
+        public override Task<int> ReadAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken) => throw new NotSupportedException(SR.NotSupported);
+
+        public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) => throw new NotSupportedException(SR.NotSupported);
     }
 }

src/libraries/System.IO.Compression/src/System/IO/Compression/ZipArchiveEntry.cs

@@ -1437,6 +1437,18 @@ public override int Read(byte[] buffer, int offset, int count)
                 throw new NotSupportedException(SR.ReadingNotSupported);
             }
 
+            public override Task<int> ReadAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)
+            {
+                ThrowIfDisposed();
+                throw new NotSupportedException(SR.ReadingNotSupported);
+            }
+
+            public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
+            {
+                ThrowIfDisposed();
+                throw new NotSupportedException(SR.ReadingNotSupported);
+            }
+
             public override long Seek(long offset, SeekOrigin origin)
             {
                 ThrowIfDisposed();

src/libraries/System.IO.Compression/src/System/IO/Compression/ZipCustomStreams.cs

@@ -486,6 +486,18 @@ public override int Read(byte[] buffer, int offset, int count)
             throw new NotSupportedException(SR.ReadingNotSupported);
         }
 
+        public override Task<int> ReadAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)
+        {
+            ThrowIfDisposed();
+            throw new NotSupportedException(SR.ReadingNotSupported);
+        }
+
+        public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
+        {
+            ThrowIfDisposed();
+            throw new NotSupportedException(SR.ReadingNotSupported);
+        }
+
         public override long Seek(long offset, SeekOrigin origin)
         {
             ThrowIfDisposed();
@@ -604,5 +616,20 @@ protected override void Dispose(bool disposing)
             }
             base.Dispose(disposing);
         }
+
+        public override async ValueTask DisposeAsync()
+        {
+            if (!_isDisposed)
+            {
+                // if we never wrote through here, save the position
+                if (!_everWritten)
+                    _initialPosition = _baseBaseStream.Position;
+                if (!_leaveOpenOnClose)
+                    await _baseStream.DisposeAsync().ConfigureAwait(false); // Close my super-stream (flushes the last data)
+                _saveCrcAndSizes?.Invoke(_initialPosition, Position, _checksum, _baseBaseStream, _zipArchiveEntry, _onClose);
+                _isDisposed = true;
+            }
+            await base.DisposeAsync().ConfigureAwait(false);
+        }
     }
 }