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

回答

相關問題