@Test(expected = NullPointerException.class) public void createWithoutStage() { factory.create(null, null); }
@Override public <I, O> ProcessingStage<I, O> create(Engine engine, Stage.Limit stage) { long limit = stage.getLimit(); return source -> (Flowable<O>) source.limit(limit); }
LimitStageFactory implements ProcessingStageFactory<Stage.Limit> { @Override public <I, O> ProcessingStage<I, O> create(Engine engine, Stage.Limit stage) { long limit = stage.getLimit(); return source -> (Flowable<O>) source.limit(limit); } }
LimitStageFactory implements ProcessingStageFactory<Stage.Limit> { @Override public <I, O> ProcessingStage<I, O> create(Engine engine, Stage.Limit stage) { long limit = stage.getLimit(); return source -> (Flowable<O>) source.limit(limit); }  }
LimitStageFactory implements ProcessingStageFactory<Stage.Limit> { @Override public <I, O> ProcessingStage<I, O> create(Engine engine, Stage.Limit stage) { long limit = stage.getLimit(); return source -> (Flowable<O>) source.limit(limit); }  @Override ProcessingStage<I, O> create(Engine engine, Stage.Limit stage); }
LimitStageFactory implements ProcessingStageFactory<Stage.Limit> { @Override public <I, O> ProcessingStage<I, O> create(Engine engine, Stage.Limit stage) { long limit = stage.getLimit(); return source -> (Flowable<O>) source.limit(limit); }  @Override ProcessingStage<I, O> create(Engine engine, Stage.Limit stage);  }