GZipCompressor.cs

using System.IO;
using System.IO.Compression;
using Archiver.Interfaces;

namespace Archiver
{
    public class GZipCompressor : AbstractProcessor
    {
        public override CompressionType Type => CompressionType.GZip;
        public override CompressionMode Mode => CompressionMode.Compress;

        public GZipCompressor(Options options) : base(options)
        {
        }

        protected override void ExecuteChunk(IChunk chunk)
        {
            using (var memoryStream = new MemoryStream())
            {
                using (var gzipStream = new GZipStream(memoryStream, CompressionMode.Compress))
                {
                    gzipStream.Write(chunk.Body, 0, chunk.Body.Length);
                    gzipStream.Flush();
                }
                chunk.Body = memoryStream.ToArray();
            }
        }
    }
}