BackpressureIntroduction In RxJava it is not difficult to get into a situation in which an Observable is emitting items more rapidly than an operator or subscriber can consume them. This presents the problem of what to do with such a growing backlog of unconsumed items. For example, imagine using the zip operator to zip together two infinite Observables, one of which emits items twice as frequently as the oth
