In the previous chapter, we generated streams of data by using a Reactor Flux and then consumed it in a subscriber. Reactor also provides a diverse set of operators that can be used to manipulate data. These operators take a stream as input and then generate another stream of another type of data. In a nutshell, these operators provide a powerful way to compose readable data pipelines. There are various operators for filtering, mapping, and collecting data. All of them will be covered in this chapter.
This chapter will cover the following topics:
- Filtering data
- Converting data
