Problem with Flowable.generate() (RxJava 2)

[smiklos]

I'm using RxJava version 2.0.2 and wanted to implement a some logic using Flowable.generate.

Based on the documentation, if I emit more than one item in when calling onNext on the emitter instance, I should get an IllegalStateException, but in reality I experience a different behavior:

Taking this example:

 Flowable<Object> test = Flowable.generate(emitter -> {
            emitter.onNext("test");
            emitter.onNext("test more");
        }).observeOn(Schedulers.io(), false,5)
          .doOnNext(System.out::println);
        test.blockingSubscribe();

I get this error: io.reactivex.exceptions.MissingBackpressureException: Queue is full?!

and if I just try:

    Flowable<Object> test = Flowable.generate(emitter -> {
            emitter.onNext("test");
            emitter.onNext("test more");
        })
       .doOnNext(System.out::println);
        test.subscribe();

then it just pushes the values indefinitely.

[akarnokd]

Thanks, this is a bug with generate not having the necessary safeguards. I'll post a fix shortly.

[akarnokd]

Closing via #4932