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

using System;

namespace Avalonia.Base.UnitTests.Styling
{
    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.");
            }
        }
    }
}