Rx:忽略订阅服务器导致的更新

做你所说的事没有固定的方法。这里有一个简单的 SkipWhen

public static IObservable<TSource> SkipWhen(this IObservable<TSource> source, 
    IObservable<TOther> other)
{
    return Observable.Defer<TSource>(() =>
    {
        object lockObject = new object();
        Stack<TOther> skipStack = new Stack<TOther>();

        other.Subscribe(x => { lock(lockObject) { skipStack.Push(x); });

        return source.Where(_ =>
        {
            lock(lockObject);
            {
                if (skipStack.Count > 0)
                {
                    skipStack.Pop();
                    return false;
                }
                else
                {
                    return true;
                }
            }
        });
    });
}

你的代码会像这样更新(见下面的注释):

INotifyPropertyChanged source;
INotifyPropertyChanged target;

// See the link at the bottom of my answer
var sourcePropertyChanged = source.GetPropertyChangeValues(x => x.SourceProperty);

// Unit is Rx's "void"
var targetChangedLocally = new Subject<Unit>();

var targetPropertyChanged = target.GetPropertyChangeValues(x => x.TargetProperty)
    .SkipWhen(targetChangedLocally);

sourcePropertyChanged
    .TakeUntil(targetPropertyChanged)
    .ObserveOnDispatcher()
    .Subscribe(_ =>
    {
        targetChangedLocally.OnNext();
        /*Raises target.PropertyChanged for targetPropertyName*/
    });

注:我最近在博客上提到 a strongly typed IObservable wrapper around INotifyPropertyChanged events

没有内置的方法,但是您可以使用 Where 可观测的可拓方法。要筛选的条件将是事件的发件人。我想 target.PropertyChanged 事件不同于 PropertyChanged 其他源引发的事件。

用这种方法在Rx中使用锁是可以的。锁是短暂的,不会调用用户代码。