- Asynchronous
- Backpressured
- incremental
- potentially infinite data processing systems
All data is send between above entities asynchronously with backpressures
- Source (Publishers)
- Sink (Subscribers)
- Flow (Processor)
We can created connected components
Upstream => To the source Downstream => To the sink