@Test
public void testUnsubscribeFromNextWhenInterrupted() throws InterruptedException {

    new InterruptionTests().assertUnsubscribeIsInvoked("next()", new Action1<BlockingObservable<Void>>() {
        @Override
        public void call(final BlockingObservable<Void> o) {
            o.next().iterator().next();
        }
    });
}