I’m moving over to   See you there!


Various implementations of Rx

I’m starting to lose track of the various ports/implementations of Rx out there. So I figured I’d list the ones I’m aware of here (and please let me know if you know of others!)   Rx .NET RxJS (JavaScript) Rx CPP RxJava Reactive Cocoa RxPython Reactive-Dart Rx.rb (Ruby)   This is pretty cool, because effectively…


Computing event duration using Rx

If you’ve looked at IIS logs, you’ve probably noticed that there are events for when a request is received and when the response is sent (see a typical request). It’s useful to understand average duration per request if you’re examining the health of your system. Alas, there’s no “duration” event. Sure, you can parse the…


A few English-to-Rx examples

Thanks to Erik Meijer for teaching me some of these patterns and reviewing the post. Thanks to Mark Simms and Curt Peterson for comments and reviews. Mark Simms and I have decided to start a new habit: If we find ourselves answering a similar question thrice, we’ll blog about it. Without further ado, here are…


How to express common windowing patterns using Rx

When processing continuous streams, one is usually interested in continuous answers broken into epochs or periods of time. Usually, the computations one formulates feel more like “compute the average speed per road segment every 5 minutes” than “what is the average speed in this road segment given all the data I’ve seen?” If you’ve been…


What I think lurks behind the Big Data meme

Some buzzwords can be annoying. Regardless of what your opinion is about the Big Data meme, you’d be hard-pressed to ignore the massive mindshare the term has gained. I think our industry is in danger of getting lost in the rhetoric and chatter, instead of remaining laser-focused on the actual problems that need solving. I’d…


A simple feedback loop in Rx

Feedback loops are very common and incredibly useful. Unsurprisingly, my colleagues and I keep finding these loops in distributed systems. I thought I’d blog about a simple pattern to express them in Rx. Many thanks to Valery Mizonov, Erik Meijer, and Colin Meek for a fruitful discussion about this topic. Consider a data source emitting…


Sequences and StreamInsight: Initiating a computation

Colin Meek, Alex Raizman, and I recently blogged about the various gestures that initiate a computation in StreamInsight. The discussion is most relevant with Sequence Integration when the StreamInsight engine is hosted in-memory. Check it out: