@Test
public void blockingGetErrorInterrupt() {

    final BlockingMultiObserver<Integer> bmo = new BlockingMultiObserver<Integer>();
    Thread.currentThread().interrupt();
    try {
        assertTrue(bmo.blockingGetError() instanceof InterruptedException);
    } finally {
        Thread.interrupted();
    }
}