Because your upstream has to be somehow "notified"...
# rx
g
Because your upstream has to be somehow "notified" about flatMap's ongoing work