linux-packaging-mono/mcs/class/System.IO.Compression/SharpCompress/IO/AppendingStream.cs

using System;
using System.Collections.Generic;
using System.IO;

namespace SharpCompress.IO
{
    internal class ReadOnlyAppendingStream : Stream
    {
        private readonly Queue<Stream> streams;
        private Stream current;

        public ReadOnlyAppendingStream(IEnumerable<Stream> streams)
        {
            this.streams = new Queue<Stream>(streams);
        }

        public override bool CanRead
        {
            get { return true; }
        }

        public override bool CanSeek
        {
            get { return false; }
        }

        public override bool CanWrite
        {
            get { return false; }
        }

        public override void Flush()
        {
            throw new NotImplementedException();
        }

        public override long Length
        {
            get { throw new NotImplementedException(); }
        }

        public override long Position
        {
            get
            {
                throw new NotImplementedException();
            }
            set
            {
                throw new NotImplementedException();
            }
        }

        public override int Read(byte[] buffer, int offset, int count)
        {
            if (current == null && streams.Count == 0)
            {
                return -1;
            }
            if (current == null)
            {
                current = streams.Dequeue();
            }
            int totalRead = 0;
            while (totalRead < count)
            {
                int read = current.Read(buffer, offset + totalRead, count - totalRead);
                if (read <= 0)
                {
                    if (streams.Count == 0)
                    {
                        return totalRead;
                    }
                    else
                    {
                        current = streams.Dequeue();
                    }
                }
                totalRead += read;
            }
            return totalRead;
        }

        public override long Seek(long offset, SeekOrigin origin)
        {
            throw new NotImplementedException();
        }

        public override void SetLength(long value)
        {
            throw new NotImplementedException();
        }

        public override void Write(byte[] buffer, int offset, int count)
        {
            throw new NotImplementedException();
        }
    }
}