Contrived RxJava2 Interrupted Thread Example

ContrivedTest.java

package com.quran.labs.androidquran.model.bookmark;

import org.junit.Test;

import io.reactivex.Single;
import io.reactivex.observers.TestObserver;
import io.reactivex.schedulers.Schedulers;

public class ContrivedTest {

  private Single<Integer> fakeDataPiece() {
    return Single.fromCallable(() -> 1)
        .subscribeOn(Schedulers.io());
  }

  private Single<String> handleDataObservable() {
    return Single.zip(fakeDataPiece(), fakeDataPiece(), fakeDataPiece(),
        (one, two, three) -> one + two + three)
        .flatMap(result -> Single.just(handleResult(result)))
        .subscribeOn(Schedulers.io());
  }

  private String handleResult(Integer data) throws InterruptedException {
    if (Thread.currentThread().isInterrupted()) {
      throw new InterruptedException("interrupted thread");
    }
    return "result is: " + data;
  }

  @Test
  public void testInterruption() {
    TestObserver<String> testObserver = new TestObserver<>();
    handleDataObservable()
        .subscribe(testObserver);
    testObserver.awaitTerminalEvent();
    testObserver.assertNoErrors();
  }
}