Netflix/RxJava — pull request #1583 by benjchristensen (2014-08-14 19:48:48+00:00)
Title: Redo/Repeat Backpressure

Fix backpressure and memory leaks

This now works:

```java
public static void main(String[] args) {
Observable o1 = Observable.from(1, 1).concatWith(Observable.just(-1).repeat());
Observable o2 = Observable.from(2, 2, 2, 2);
Observable.zip(o1, o2, (a, b) -> a + b).forEach(System.out::println);
}
```