2.x: Observable.repeatWhen doesn't call onComplete

[otal1105]

I tried below

Observable.range(1, 3).repeatWhen(handler -> handler.take(2))
    .subscribe(
        System.out::println, 
        e -> e.printStackTrace(),
        () -> System.out.println("completed"));

It dodin't call onComplete. I got this.

1
2
3
1
2
3
1
2
3

However, I tried Flowable, it called onComplete.

Flowable.range(1, 3).repeatWhen(handler -> handler.take(2))
    .subscribe(
        System.out::println, 
        e -> e.printStackTrace(),
        () -> System.out.println("completed"));

The result was below.

1
2
3
1
2
3
completed

I tried on 2.0.2.

[akarnokd]

Thanks. This is a bug with Observable.repeat. I'll post a fix shortly.

[akarnokd]

See #4911.

[akarnokd]

Closing via #4911