11 End-to-end real-time reactive event processing
This chapter covers
- Combining RxJava operators and Vert.x clients to support advanced processing
- Using RxJava operators to perform content enrichment and aggregate data processing on top of event streams
- Extending the Vert.x event bus to web applications to unify backend and frontend communication models
- Managing state in a stream-processing setting
In this chapter we’ll explore advanced reactive stream processing, where application state is subject to live changes based on events. By performing transformations and aggregations on events, we will compute live statistics about what is happening in the larger 10k steps application. You will also see how event streams can impact real-time web ...
Get Vert.x in Action now with the O’Reilly learning platform.
O’Reilly members experience books, live events, courses curated by job role, and more from O’Reilly and nearly 200 top publishers.
