5:00 PM Saturday
Silicon Valley Code Camp : October 11th and 12th 2014session

Reactive Programming with DDS and Rx

Rx4DDS.NET: Reactive Programming using RTI Connext DDS and Microsoft Rx

About This Session

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.

Time: 5:00 PM Saturday    Room: 4202 

The Speaker(s)

undefined undefined

Sumant Tambe

Senior Software Engineer , LinkedIn

Kafka-Dev, Microsoft MVP, Open-Source Contributor, Blogger, Author, Father, and Gamer