“Reactive Stream Processing in Industrial IoT using DDS and Rx.cpp”
summary
Claims a practical C++ pattern for composable, low-latency stream processing by wiring RxCpp pipelines to DDS (RTI Connext) and the rx4dds bridge. Demonstrations build a live “shapes” system that spawns per-key pipelines (squares → orbiting circles and triangles), a dynamic group-by that creates and tears down pipelines on key lifetime, and a correlator that averages active keys; prototype sustains about 250,000 samples/sec on a single laptop and the demos run end-to-end.
AI-written summary · about
chapters (26)
- 0:00Introduction to Agenda
- 1:08Industrial IOT Overview
- 2:18IOT System Challenges
- 3:44Reactive System Principles
- 5:08Data Distribution Service
- 7:48Reactive API Choice
- 8:57Stream Processing Concepts
- 10:06Reactive Extensions Design
- 12:20Observables and Composition
- 13:17RX Contract and Duality
- 16:06Observable vs Future
- 17:55RX CPP Code Example
- 19:35Data Pipeline Operators
- 21:34Marble Diagrams Explained
- 22:32Asynchronous Composition
- 25:34Integrating RX with DDS
- 27:44Shapes Demo Introduction
- 31:26Solar System Simulation
- 33:06Lifecycle Management
- 37:30Stateful Transformations
- 40:14RX Operator Implementation
- 42:03Sharding Data Pipelines
- 46:22Grouping and Flatmap
- 51:45Dynamic Correlation
- 57:46RXCPP Complexity Analysis
- 1:00:21Q&A and Resources
related talks
21mReal-Time Stream Processing with Reactive-Extensions (RX)
38mCuring your event processing blues with Rx
32mReal-Time Stream Processing with Reactive-Extensions
45mReactive programming with Rx and C#
56mThirst-quenching Streams for the Reactive Mind
50mThe reactive landscape
32mThirst-Quenching Streams for the Reactive Mind
01h 32mBuilding Reactive applications with Reactor and the Reactive Streams standard