Multiple Zipped Observers never complete

[stevemenke]

The following code never executes the onComplete if the number is greater than 1025. I think it has to due with back pressure which uses a default request of 1024. I am using Java 8

    Observable merged1 = Observable.zip(Observable.range(0, 1026), Observable.range(0, 1026),
            (o, e) -> new int[]{o, e});
    Observable merged2 = Observable.<int[], Integer, int[]>zip(merged1, Observable.range(0, 1026),
            (o, e) -> new int[]{o[0], o[1], e}).serialize();
    merged2.subscribe(
            (o) -> System.out.println(o),
            e -> {},
            () -> {
                System.out.println("This never prints");
            }
    );

I am using the following version of Java.

java version "1.8.0_05"
Java(TM) SE Runtime Environment (build 1.8.0_05-b13)
Java HotSpot(TM) 64-Bit Server VM (build 25.5-b02, mixed mode)

[zsxwing]

Thanks for reporting it.