@Test
public void blockingGetErrorTimeoutInterrupt() {

    final BlockingMultiObserver<Integer> bmo = new BlockingMultiObserver<Integer>();
    Thread.currentThread().interrupt();
    try {
        bmo.blockingGetError(1, TimeUnit.MINUTES);
        fail("Should have thrown");
    } catch (RuntimeException ex) {
        assertTrue(ex.getCause() instanceof InterruptedException);
    } finally {
        Thread.interrupted();
    }
}