Book Image

C++ Reactive Programming

By : Praseed Pai, Peter Abraham
Book Image

C++ Reactive Programming

By: Praseed Pai, Peter Abraham

Overview of this book

Reactive programming is an effective way to build highly responsive applications with an easy-to-maintain code base. This book covers the essential functional reactive concepts that will help you build highly concurrent, event-driven, and asynchronous applications in a simpler and less error-prone way. C++ Reactive Programming begins with a discussion on how event processing was undertaken by different programming systems earlier. After a brisk introduction to modern C++ (C++17), you’ll be taken through language-level concurrency and the lock-free programming model to set the stage for our foray into the Functional Programming model. Following this, you’ll be introduced to RxCpp and its programming model. You’ll be able to gain deep insights into the RxCpp library, which facilitates reactive programming. You’ll learn how to deal with reactive programming using Qt/C++ (for the desktop) and C++ microservices for the Web. By the end of the book, you will be well versed with advanced reactive programming concepts in modern C++ (C++17).

Related Content you might be interested in

Current Title:

Small book image
C++ Reactive Programming
Praseed Pai | Peter Abraham
Jun, 2018 | 348 pages
Small book image
.NET Design Patterns
Praseed Pai | Shine Xavier
Jan, 2017 | 314 pages
Small book image
Mastering C++ Programming
Jeganathan Swaminathan
Sep, 2017 | 384 pages
Small book image
Mastering C++ Multithreading
Maya Posch
Jul, 2017 | 244 pages
Table of Contents (20 chapters)
Title Page
Title Page
Copyright and Credits
Copyright and Credits
Packt Upsell
Packt Upsell
Contributors
Contributors
Preface
Preface
Free Chapter
1
Reactive Programming Model – Overview and History
Reactive Programming Model – Overview and History
Event-driven programming model
Reactive programming model
Functional reactive programming
The key interfaces of a reactive program
Pull-versus push-based reactive programming
Converting events to IObservable<T>
The philosophy of our book
Summary
2
A Tour of Modern C++ and its Key Idioms
A Tour of Modern C++ and its Key Idioms
The key concerns of the C++ programming language
Enhancements to C++ for writing better code
Composing functions together with the pipe operator
Miscellaneous features
Range-based for loops and observables
Summary
3
Language-Level Concurrency and Parallelism in C++
Language-Level Concurrency and Parallelism in C++
What is concurrency?
Hello World of concurrency (using std::thread)
Managing threads
Using Lambdas
Sharing data between threads
A thread-safe stack data structure
Summary
4
Asynchronous and Lock-Free Programming in C++
Asynchronous and Lock-Free Programming in C++
Task-based parallelism in C++
C++ memory model
Memory access and concurrency
The modification contract
Atomic operations and types in C++
Atomic types
Memory ordering
A lock-free data structure  queue
Summary
5
Introduction to Observables
Introduction to Observables
The GoF Observer pattern
The limitations of the GoF Observer pattern
A holistic look at GoF patterns
The OOP programming model and hierarchies
A Composite/Visitor pattern for expression processing
Flattening the composite for iterative processing
Map and filter operations on the list
Reversing the gaze for Observables!
Summary
6
Introduction to Event Stream Programming Using C++
Introduction to Event Stream Programming Using C++
What is Stream programming model?
Applied Stream programming using the Streams library
Lazy evaluation
Event Stream programming
Summary
7
Introduction to Data Flow Computation and the RxCpp Library
Introduction to Data Flow Computation and the RxCpp Library
The data flow computation paradigm
An introduction to the RxCpp library
Creating Observables from the scratch
An introduction to marble diagrams for visual representation
RxCpp (Stream) Operators
A peek into the things we haven't covered yet
Summary
8
RxCpp – the Key Elements
RxCpp – the Key Elements
Observables
Observers and their variants (Subscribers)
Subjects
Schedulers
Operators
Summary
9
Reactive GUI Programming Using Qt/C++
Reactive GUI Programming Using Qt/C++
A quick introduction to Qt GUI programming
Hello World – Qt program
Qt event model with signals/slots/MOC – an example
Integrating the RxCpp library with the Qt event model
Summary
10
Creating Custom Operators in RxCpp
Creating Custom Operators in RxCpp
Philosophy of Rx operators
Chaining stock operators
Writing basic RxCpp custom operators
Different genres of custom operators
Writing custom operators that can be chained
Summary
11
Design Patterns and Idioms for C++ Rx Programming
Design Patterns and Idioms for C++ Rx Programming
The OOP and Design patterns movement
Key Pattern catalogs
The Design pattern redux
From Design patterns to Reactive programming
The Cell pattern
The Active object pattern
The Resource Loan pattern
The Event bus pattern
Summary
12
Reactive Microservices Using C++
Reactive Microservices Using C++
The C++ language and web programming
The C++ REST SDK
Testing the HTTP server using CURL and POSTMAN
The JSON and HTTP protocol
The C++ REST SDK-based REST server
Invoking REST services using the RxCurl library
A word about the Reactive micro-services architecture
Summary
13
Advanced Streams and Handling Errors
Advanced Streams and Handling Errors
A short recap of the characteristics of a reactive system
RxCpp error and exception handling Operators
Schedulers and error handling
Event-based Stream handling – some examples
Summary
Other Books You May Enjoy
Other Books You May Enjoy
Leave a review - let other readers know what you think
Index
Index

The C++ REST SDK-based REST server

Note

In this section, we have leveraged code from Marius Bancila's excellent article about the C++ REST SDK. In fact, the key/value database code is borrowed from his implementation. The authors are thankful to him for the excellent article, available at https://mariusbancila.ro/blog/2017/11/19/revisited-full-fledged-client-server-example-with-c-rest-sdk-2-10/.

 

 

 

Let's write a micro-service application that puts everything together we have learned so far in the context of Microsoft C++ REST SDK. We will consume REST services by leveraging the RxCurl library written by Kirk Shoop, as part of his Twitter analysis application. We have added support to the DELETE and PUT verbs, as the original implementation contained only support for GET and POST verbs. The REST service implemented here supports the following verbs:

  • GET: Lists all the key/value pairs in the storage. The response will be in the { key:value,key:value} format.
  • POST: Retrieves values corresponding...
Previous Section
End of Section 6
Next Section