Reactive Programming in Kotlin

Operator

When we started with programming for the first time, we learned about operators. We learned that operators are those special characters/sequence of characters that perform some specific tasks on the operands and return the final results. In the reactive world, the definition remains merely the same; they take one or more Observable/Flowable as operands, transform them, and return the resultant Observable/Flowable.

Operators work such as a consumer to the preceding Observable/Flowable, listen to their emissions, transform them, and emit them to the downstream consumer. For instance, think of the map operator, it listens to the upstream producer, performs some operations on their emissions, and then emits those modified items to the ...