@Test(expected = NullPointerException.class) public void createWithoutStage() { factory.create(null, null); }
@Override public <I, O> ProcessingStage<I, O> create(Engine engine, Stage.Skip stage) { long skip = stage.getSkip(); return source -> (Flowable<O>) source.skip(skip); }
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); } }
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); }  }
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); }  @Override ProcessingStage<I, O> create(Engine engine, Stage.Skip stage); }
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); }  @Override ProcessingStage<I, O> create(Engine engine, Stage.Skip stage);  }