    @Test
    public void shouldUnsubscribeFromSourceSequenceWhenPredicateFailsToPass() {

        OperatorConditionalBinding<String, Object> op = new OperatorConditionalBinding<String, Object>(
                new Object(), UtilityFunctions.alwaysFalse());

        Subscriber<? super String> sub = op.call(subscriber);
        sub.onNext("one");
        sub.onNext("two");
        sub.onCompleted();
        sub.onError(new Exception());

        assertEquals(0, subscriber.getOnNextEvents().size());
        assertEquals(0, subscriber.getOnCompletedEvents().size());
        assertEquals(0, subscriber.getOnErrorEvents().size());
    }