class SkipStageFactory implements ProcessingStageFactory<Stage.Skip> {

    @Override
    public <I, O> ProcessingStage<I, O> create(Engine engine, Stage.Skip stage) {
        long skip = stage.getSkip();
        return source -> (Flowable<O>) source.skip(skip);
    }

}