ContentResponse.cs

using System;
using System.Threading.Tasks;
using Waher.Events;
 
namespace Waher.Content
{
    public class ContentResponse : IDisposableAsync
    {
        private readonly object decoded;
        private readonly bool hasError;
 
        public ContentResponse(string ContentType, object Decoded, byte[] Encoded)
        {
            this.decoded = Decoded;
            this.hasError = false;
            
            this.ContentType = ContentType;
            this.Encoded = Encoded;
            this.Error = null;
        }
 
        public ContentResponse(Exception Error)
        {
            this.decoded = null;
            this.hasError = true;
 
            this.ContentType = null;
            this.Encoded = null;
            this.Error = Error;
        }
 
        public string ContentType { get; }
 
        public object Decoded 
        {
            get
            {
                if (this.hasError)
                    throw this.Error;
                else
                    return this.decoded;
            }
        }
 
        public byte[] Encoded { get; }
 
        public bool HasError => this.hasError;
 
        public Exception Error { get; }
 
        [Obsolete("Use DisposeAsync() instead.")]
        public void Dispose()
        {
            this.DisposeAsync().Wait();
        }
 
        public async Task DisposeAsync()
        { 
            if (this.Decoded is IDisposableAsync DisposableAsync)
                await DisposableAsync.DisposeAsync();
            else if (this.Decoded is IDisposable Disposable)
                Disposable.Dispose();
        }
 
        public void AssertOk()
        {
            if (this.hasError)
                throw this.Error;
        }
    }
}