Skip to content

Multiple Zipped Observers never complete #1812

Closed

Description

@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)

Activity

  1. added a commit that references this issue on Oct 31, 2014
  2. zsxwing commented on Oct 31, 2014

    @zsxwing
    Member

    Thanks for reporting it.

  3. added a commit that references this issue on Oct 31, 2014
  4. added this to the 1.0 milestone on Oct 31, 2014
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

      Milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions