A few days ago , intentionally or not, a version of the Reactive Framework was released into the wild . Let’s see how we can use the RX for computations on a stream of data. As an example we’ll take a stream of ints and produce the averages in groups of five.   Here’s the primary stream of numbers...

One compelling feature of StreamInsight is it’s in-process hosting model. In addition to reducing the complexity of server side installs, it’s now possible to have a  CEP engine in the client UI. The simplest way of getting CEP streams onto the UI would be the Reactive Framework methods. Something...

In my last post I showed how to send StreamInsight output streams to a UI via the ReactiveFramework . Here’s we’ll do the reverse, by sending an RX stream into a CEP stream. Instead of a partial example, I’ll use an end to end example showing simulated stock ticks, computing the 5 min rolling VWAP ,...

The bug I mentioned in my first attempt at a sliding window was the minor issue that the aggegates never went down to 0, even if the window had emptied out. The problem line of code was cur.GroupBy(tsst => tsst.Value.Symbol) – if the window is empty, there is nothing to group – and as a result the...

Streaming OLAP is something that comes up over and over again in the “CEP space” – using the Reactive Extensions for .Net this demo shows the basics; filtering, grouping, aggregates, and concurrent queries. To set the context, the idea here is focus on the “query” side, so the UI is aggressively simple...