@Test(expected = NullPointerException.class) public void createWithoutError() { factory.create(null, () -> null); }
@Override public <O> PublisherStage<O> create(Engine engine, Stage.Failed stage) { Throwable error = Objects.requireNonNull(Objects.requireNonNull(stage).getError()); return () -> Flowable.error(error); }
FailedPublisherStageFactory implements PublisherStageFactory<Stage.Failed> { @Override public <O> PublisherStage<O> create(Engine engine, Stage.Failed stage) { Throwable error = Objects.requireNonNull(Objects.requireNonNull(stage).getError()); return () -> Flowable.error(error); } }
FailedPublisherStageFactory implements PublisherStageFactory<Stage.Failed> { @Override public <O> PublisherStage<O> create(Engine engine, Stage.Failed stage) { Throwable error = Objects.requireNonNull(Objects.requireNonNull(stage).getError()); return () -> Flowable.error(error); }  }
FailedPublisherStageFactory implements PublisherStageFactory<Stage.Failed> { @Override public <O> PublisherStage<O> create(Engine engine, Stage.Failed stage) { Throwable error = Objects.requireNonNull(Objects.requireNonNull(stage).getError()); return () -> Flowable.error(error); }  @Override PublisherStage<O> create(Engine engine, Stage.Failed stage); }
FailedPublisherStageFactory implements PublisherStageFactory<Stage.Failed> { @Override public <O> PublisherStage<O> create(Engine engine, Stage.Failed stage) { Throwable error = Objects.requireNonNull(Objects.requireNonNull(stage).getError()); return () -> Flowable.error(error); }  @Override PublisherStage<O> create(Engine engine, Stage.Failed stage);  }