WP7 - 使用 RX，订阅只触发一次但 OnNext() 总是触发？

Question

好吧，我又玩了一个响应式扩展，特别是 wp7。

我正在查看 GeoCoordinateWatcher 位置更改事件，如下所示

var subject = new BehaviorSubject<GeoCoordinate>(GeoCoordinate.Unknown);
var watcher = new GeoCoordinateWatcher(GeoPositionAccuracy.Default) { MovementThreshold = 0 };

watcher.PositionChanged += (o, args) =>
{
   var newLocation = args.Position.Location;

   if ((DateTime.Now - args.Position.Timestamp.DateTime) < locationTimeout)
   {
        subject.OnNext(newLocation);
    }
};

我是这样订阅的

MyLocation.StartGettingLocations()
 .Subscribe(pos =>
 {
       // Do something with the position
       PlotLine.Locations.Add(pos);
       bingMap.SetView(pos, 15);
 });

应用程序运行，但问题是订阅侧的代码仅发生一次，如果我在主题中设置断点。OnNext(newLocation)，我看到它不断被触发。

我做错了什么？

[编辑]

好的，我知道出了什么问题，代码（这不是我的，我只是从中学习）使用 DistinctUntilChanged()。我假设，通过简要阅读，这会阻止向订阅者输出相同的价值？所以就我使用它的目的而言，位置跟踪，如果手机在同一个位置并且地理坐标没有改变，那么将它发送给用户是没有意义的，所以它只是阻止它？

Answer 1

我怀疑问题已在 cmets 中得到解答（即，如果您想要位置，即使用户没有移动，也可以删除 DistinctUntilChanged）。但是，这个问题有些麻烦——它使用了 Rx，但不是特别有效。

首先，有一种更简单的方法可以将事件转换为可观察对象（这反过来又使它们更易于使用）：

var watcher = new GeoCoordinateWatcher(GeoPositionAccuracy.Default) { MovementThreshold = 0 };  
var geo = Observable.FromEventPattern<GeoPositionChangedEventArgs<GeoCoordinate>>(
                               ev => watcher.PositionChanged += ev, 
                               ev => watcher.PositionChanged -= ev)
                    .Select(ev => ev.EventArgs.Position);

然后，要进行更改，不需要那些命令式的代码。只需这样做：

var changes = geo.Where(pos => (DateTime.Now - pos.Timestamp.DateTime) < locationTimeout)
                 .Select(pos => pos.Location)
                 .DistinctUntilChanged();

（您当然可以删除DistinctUntilChanged，这不在您发布的代码中）。

现在您可以直接使用changes：

changes.Subscribe(loc =>
{
   PlotLine.Locations.Add(pos);
   bingMap.SetView(pos, 15);
});

没有必要管理一个实际上只是掩盖一组事件的主题。只需将事件转换为 Observables。然后因为您一直在使用 Observables，所以您可以访问许多组合器，这些组合器可以让您做的比现在更多。