Generating backpressure-aware streams with Flowable.generate() – RxJava FAQ

(Tomasz Nurkiewicz) RxJava is missing a factory to create an infinite stream of natural numbers. Such a stream is useful e.g. when you want to assign unique sequence numbers to possibly infinite stream of events by zipping both of them:

Read More - Register for Free Membership