Avalonia/src/Avalonia.Base/Data/Core/AvaloniaPropertyAccessorNode.cs

using System;
using System.Reactive.Linq;
using Avalonia.Reactive;

#nullable enable

namespace Avalonia.Data.Core
{
    public class AvaloniaPropertyAccessorNode : SettableNode
    {
        private IDisposable? _subscription;
        private readonly bool _enableValidation;
        private readonly AvaloniaProperty _property;

        public AvaloniaPropertyAccessorNode(AvaloniaProperty property, bool enableValidation)
        {
            _property = property;
            _enableValidation = enableValidation;
        }

        public override string? Description => PropertyName;
        public string? PropertyName { get; }
        public override Type PropertyType => _property.PropertyType;

        protected override bool SetTargetValueCore(object? value, BindingPriority priority)
        {
            try
            {
                if (Target.TryGetTarget(out var target) && target is IAvaloniaObject obj)
                {
                    obj.SetValue(_property, value, priority);
                    return true;
                }
                return false;
            }
            catch
            {
                return false;
            }
        }

        protected override void StartListeningCore(WeakReference<object?> reference)
        {
            if (reference.TryGetTarget(out var target) && target is IAvaloniaObject obj)
            {
                _subscription = new AvaloniaPropertyObservable<object?>(obj, _property).Subscribe(ValueChanged);
            }
            else
            {
                _subscription = null;
            }
        }

        protected override void StopListeningCore()
        {
            _subscription?.Dispose();
            _subscription = null;
        }
    }
}