Can you please add some unit tests for this? You can see examples of the pattern we follow here: https://github.com/Netflix/RxJava/blob/master/rxjava-core/src/main/java/rx/operators/OperationSkip.java#L112