101个RX示例

几天前我也有类似的想法。我们在RX的msdn论坛上发布了自己的“101个RX样本”,但后来我们将其改为wiki格式。请随时过来添加您自己的样品!

101 Rx Samples on the Rx wiki

首先-这里是一个简单的绘图应用程序,这样当用户拖动时,我们将从初始鼠标向下位置绘制一条红线到当前位置,同时在当前位置绘制一个蓝色点。这是我上周对RX的黑客攻击的结果

这是源代码。

//A draw on drag method to perform the draw
void DrawOnDrag(Canvas e)
        {

            //Get the initial position and dragged points using LINQ to Events
            var mouseDragPoints = from md in e.GetMouseDown()
                                  let startpos=md.EventArgs.GetPosition(e)
                                  from mm in e.GetMouseMove().Until(e.GetMouseUp())
                                  select new
                                  {
                                      StartPos = startpos,
                                      CurrentPos = mm.EventArgs.GetPosition(e),
                                  };


            //Subscribe and draw a line from start position to current position
            mouseDragPoints.Subscribe
                (item =>
                {
                    e.Children.Add(new Line()
                    {
                        Stroke = Brushes.Red,
                        X1 = item.StartPos.X,
                        X2 = item.CurrentPos.X,
                        Y1 = item.StartPos.Y,
                        Y2 = item.CurrentPos.Y
                    });

                    var ellipse = new Ellipse()
                    {
                        Stroke = Brushes.Blue,
                        StrokeThickness = 10,
                        Fill = Brushes.Blue
                    };
                    Canvas.SetLeft(ellipse, item.CurrentPos.X);
                    Canvas.SetTop(ellipse, item.CurrentPos.Y);
                    e.Children.Add(ellipse);
                }
                );
        }

Read my post with further explanation here 和 Download the source code here

希望这有帮助

另一个有用的资源可能是 Reactive Extensions (Rx) Koans : 55个渐进式示例帮助您学习Rx

我在读书 http://www.introtorx.com 就像名字所暗示的,这似乎是一个简明的介绍。似乎有很多(非常基本的)例子,一步一步地,主要是使用控制台打印出来的东西。

这是我的变体 drag & drop sample by Wes Dyer ,对于Windows窗体(我可能会使其启用拖动扩展方法):

    public Form2()
    {
        InitializeComponent();

        EnableDragging(pictureBox1);
        EnableDragging(button1);
        EnableDragging(this);
    }

    private void EnableDragging(Control c)
    {
        // Long way, but strongly typed.
        var downs = from down in Observable.FromEvent<MouseEventHandler, MouseEventArgs>(
                        eh => new MouseEventHandler(eh), 
                        eh => c.MouseDown += eh,  
                        eh => c.MouseDown -= eh)
                    select new { down.EventArgs.X, down.EventArgs.Y };

        // Short way.
        var moves = from move in Observable.FromEvent<MouseEventArgs>(c, "MouseMove")
                    select new { move.EventArgs.X, move.EventArgs.Y };

        var ups = Observable.FromEvent<MouseEventArgs>(c, "MouseUp");

        var drags = from down in downs
                    from move in moves.TakeUntil(ups)
                    select new Point { X = move.X - down.X, Y = move.Y - down.Y };

        drags.Subscribe(drag => c.SetBounds(c.Location.X + drag.X, c.Location.Y + drag.Y, 0, 0, BoundsSpecified.Location));
    }  

有点晚了,但是如果有新的人发现这个问题, http://rxmarbles.com/ 提供了一种非常好的可视化操作员的方法。

还有一个 Stock Viewer Github上的示例

1. SteamProvider拉取服务器并生成rx.net iobservable流。
2. SteamAggregator聚合所有IOBServable流,并将结果复制到中央处理线程中。
3. 视图过滤单个流并将结果复制到它们自己的线程中以供显示。

所有streamproviders、streamaggregate和视图都在自己的线程中运行。这也是一个典型的实际库存查看应用程序线程模型。

这个例子也可以是一个简单的WPF数据报性能测试框架。它计算每秒处理的刻度数并将其显示在视图上。