Session Details

Reactive Programming with DDS and Rx  

Level :
Intermediate
Date :
5:00 PM Saturday
Room :
4202
Interested : (50) - Registered : (6)
ADD TO CALENDAR...

Presentation

In this presentation (and a live demonstration) you will see why Reactive Extensions (Rx) is a powerful technology for asynchronous stream processing. RTI Data Distribution Service (DDS) will be used as the source of data and as a communication channel for asynchronous data streams. On top of DDS, we'll use Rx to subscribe, observe, project, filter, aggregate, merge, zip, and correlate one or more data streams (Observables). The live demo will be very visual as bouncing shapes of different colors will be transformed in front of you using C# lambdas, Rx.NET, and LinqPad. You will also learn about the new Rx4DDS.NET library that integrates RTI DDS with Rx.NET. Rx and DDS are a great match because both are reactive. Rx is based on the subject-observer pattern, which is quite analogous to the publish-subscribe pattern of DDS. When used together they support distributed dataflows seamlessly. If time permits, we will touch upon advanced Rx concepts such as stream of streams (IGroupedObservable) and how it captures DDS "keyed topics". The DDS applications using Rx4DDS.NET dramatically simplify concurrency to the extent that it can be simply configured. Sounds too good to be true? Listen to the talk and watch the demo.

The Speakers

img

Sumant Tambe

Sumant is a Principal Research Engineer at Real-Time Innovations (RTI) and a Microsoft VC++ MVP. His focus at RTI is standards-based data distribution middleware for real-time systems. He has been programming in C++ for over a decade. He likes C++ because it supports multiple paradigms. He is responsible for RefleX, Rx4DDS, C++ Truths, and More C++ Idioms. Lately, he is dabbling into Reactive Stream Processing.
  • Not Interested
  • Interested
  • Attending

SPONSORS List