@Test(timeout = 5000)
public void blockingFirstTimeout2() {

    BlockingFirstSubscriber<Integer> bf = new BlockingFirstSubscriber<Integer>();
    bf.onSubscribe(new BooleanSubscription());
    Thread.currentThread().interrupt();
    try {
        bf.blockingGet();
        fail("Should have thrown!");
    } catch (RuntimeException ex) {
        assertTrue(ex.toString(), ex.getCause() instanceof InterruptedException);
    }
}