@Test
public void testUnsubscribeFromForEachWhenInterrupted() throws InterruptedException {

    new InterruptionTests().assertUnsubscribeIsInvoked("forEach()", new Action1<BlockingObservable<Void>>() {
        @Override
        public void call(final BlockingObservable<Void> o) {
            o.forEach(new Action1<Void>() {
                @Override
                public void call(final Void aVoid) {
                    // nothing
                }
            });
        }
    });
}