UndeliverableException.java

package rxsearcher.searcher.kelkoo;

import com.google.common.util.concurrent.Uninterruptibles;
import io.reactivex.BackpressureStrategy;
import io.reactivex.Flowable;
import io.reactivex.disposables.Disposable;
import org.junit.Test;

import java.util.concurrent.TimeUnit;

public class UndeliverableException {

    @Test
    public void undeliverable() {
        //        RxJavaPlugins.setErrorHandler(t -> System.out.println(t.getMessage()));
        Flowable<Integer> flowable = Flowable.create(subscriber -> {
            new Thread(() -> {
                for (int i = 0; i < 10; i++) {
                    Uninterruptibles.sleepUninterruptibly(300, TimeUnit.MILLISECONDS);
                    subscriber.onNext(i);
                }
                subscriber.onError(new RuntimeException("Error"));
            }).start();
        }, BackpressureStrategy.MISSING);

        Disposable subscribe = flowable
                .subscribe(
                        System.out::print,
                        Throwable::printStackTrace
                );
        Uninterruptibles.sleepUninterruptibly(350, TimeUnit.MILLISECONDS);
        subscribe.dispose();

        Uninterruptibles.sleepUninterruptibly(11 * 300, TimeUnit.MILLISECONDS);
    }

}