Avalonia/tests/Avalonia.Styling.UnitTests/TestObserver.cs

// Copyright (c) The Avalonia Project. All rights reserved.
// Licensed under the MIT license. See licence.md file in the project root for full license information.

using System;

namespace Avalonia.Styling.UnitTests
{
    internal class TestObserver<T> : IObserver<T>
    {
        private bool _hasValue;

        private T _value;

        public bool Completed { get; private set; }

        public Exception Error { get; private set; }

        public T GetValue()
        {
            if (!_hasValue)
            {
                throw new Exception("Observable provided no value.");
            }

            if (Completed)
            {
                throw new Exception("Observable completed unexpectedly.");
            }

            if (Error != null)
            {
                throw new Exception("Observable errored unexpectedly.");
            }

            _hasValue = false;
            return _value;
        }

        public void OnCompleted()
        {
            Completed = true;
        }

        public void OnError(Exception error)
        {
            Error = error;
        }

        public void OnNext(T value)
        {
            if (!_hasValue)
            {
                _value = value;
                _hasValue = true;
            }
            else
            {
                throw new Exception("Observable pushed more than one value.");
            }
        }
    }
}