RxCPP行为不同于Rx.Net

我正在使用RxCPP，并且难以理解其行为。RxCPP行为不同于Rx.Net

这里有两个程序，一个在Rx.Net中，另一个在RxCPP中。他们假设输出相同的照片，但他们不。
该程序从鼠标流中获取点数，并计算点之间的三角洲流。
鼠标是一串流的点，每一笔 - 从下往上按是一个流。老鼠一个接一个地给这些流。

在这些试验中的期望的输出是：
德尔塔无0：0,0
德尔塔无1：5,0
德尔塔无2是：0,5
德尔塔无3是：2,3
这是Rx.Net输出的内容。
Rx.Cpp只输出第一行：Delta no 0是：0,0

任何想法？

Rx.Cpp例如：

#include <rx.hpp> 
    namespace rx = rxcpp; 
    namespace rxsub = rxcpp::subjects; 
    using rxob = rx::observable<>; 

    struct Point 
    { 
     Point(int x, int y) : x(x), y(y) {} 

     int x = 0, y = 0; 
     Point operator-() const { return {-x, -y}; } 
     Point operator+(const Point& other) const { return Point{x + other.x, y + other.y}; } 
     Point operator-(const Point& other) const { return operator+(-other); } 
    }; 

    std::ostream& operator<<(std::ostream& o, const Point& p) 
    { 
     return o << "(" << p.x << ", " << p.y << ")"; 
    } 

    void TestRxCPP() 
    { 
     using RxPoint = rx::observable<Point>; 
     using Strokes = rx::observable<RxPoint>; 
     using StrokesSubject = rxsub::subject<RxPoint>; 

     StrokesSubject mouseSource; 
     auto strokes = mouseSource.get_observable(); 

     auto deltaVectors = [](Strokes strokes) { 
     auto deltas = strokes.flat_map([=](RxPoint stroke) { 
      auto points = stroke; 
      // create stream of delta vectors from start point 
      auto firstPoint = points.take(1); 
      auto delta = 
       points.combine_latest([](Point v0, Point v1) { return v0 - v1; }, firstPoint); 
      return delta; 
     }); 

     return deltas; 
     }; 

     auto delta = deltaVectors(strokes); 
     int n = 0; 
     delta.subscribe(
     [&](const Point& d) { std::cout << "Delta no. " << n++ << " is: " << d << std::endl; }); 

     auto testMouse = rxob::from(Point{3 + 0, 4 + 0}, Point{3 + 5, 4 + 0}, Point{3 + 0, 4 + 5}, Point{3 + 2, 4 + 3}); 
     mouseSource.get_subscriber().on_next(testMouse); 
    }

Rx.Net例如：

void RxNET() 
    { 
     var strokesS = new Subject<IObservable<Point>>(); 

     Func<IObservable<IObservable<Point>>, IObservable<Point>> 
     deltaVectors = strokes => 
     { 
      var deltas = strokes.SelectMany(stroke => 
      { 
       var points = stroke; 
       // create stream of delta vectors from start point 
       var firstPoint = points.Take(1); 
       var deltaP = 
        points.CombineLatest(firstPoint, (v0, v1) => new Point(v0.X - v1.X, v0.Y - v1.Y)); 
       return deltaP; 
      }); 

      return deltas; 
     }; 

     var delta = deltaVectors(strokesS); 
     var n = 0; 
     delta.Subscribe(d => { Console.WriteLine($"Delta no {n++} is: {d}\n"); }); 

     var testMouse = new List<Point> 
     { 
      new Point(3 + 0, 4 + 0), 
      new Point(3 + 5, 4 + 0), 
      new Point(3 + 0, 4 + 5), 
      new Point(3 + 2, 4 + 3) 
     }.ToObservable(); 
     strokesS.OnNext(testMouse); 
    }

来源

2017-08-13 ShaulF

您是否尝试过使用调试器或包括跟踪语句找出的功能将两片岔开

冷热源是否行得通呢？ –

它很难（对我来说）调试rxcpp库，它的非常高端的C++ :-( – ShaulF

Thanks to @Kirk Shoop at the rxcpp github :-)
这是一个HOTvCOLD行为。

笔画是冷的，正在被共享，只有一个线程被使用。 points.combine_latest(..., firstPoint)表示所有点数在firstPoint订阅之前发送。因此仅发射最后的三角洲。如果你扭转combine_latest

auto delta = 
    firstPoint.combine_latest([](Point v0, Point v1) { return v1 - v0; }, points);

来源

2017-08-14 16:24:18 ShaulF

RxCPP行为不同于Rx.Net

回答

相关问题