@Test(expected = NullPointerException.class) public void createWithoutFunction() { factory.create(null, () -> null); }
@SuppressWarnings("unchecked") @Override public <O> PublisherStage<O> create(Engine engine, Stage.PublisherStage stage) { Publisher<O> publisher = (Publisher<O>) Objects.requireNonNull(Objects.requireNonNull(stage.getRsPublisher())); return () -> Flowable.fromPublisher(publisher); }
FromPublisherStageFactory implements PublisherStageFactory<Stage.PublisherStage> { @SuppressWarnings("unchecked") @Override public <O> PublisherStage<O> create(Engine engine, Stage.PublisherStage stage) { Publisher<O> publisher = (Publisher<O>) Objects.requireNonNull(Objects.requireNonNull(stage.getRsPublisher())); return () -> Flowable.fromPublisher(publisher); } }
FromPublisherStageFactory implements PublisherStageFactory<Stage.PublisherStage> { @SuppressWarnings("unchecked") @Override public <O> PublisherStage<O> create(Engine engine, Stage.PublisherStage stage) { Publisher<O> publisher = (Publisher<O>) Objects.requireNonNull(Objects.requireNonNull(stage.getRsPublisher())); return () -> Flowable.fromPublisher(publisher); }  }
FromPublisherStageFactory implements PublisherStageFactory<Stage.PublisherStage> { @SuppressWarnings("unchecked") @Override public <O> PublisherStage<O> create(Engine engine, Stage.PublisherStage stage) { Publisher<O> publisher = (Publisher<O>) Objects.requireNonNull(Objects.requireNonNull(stage.getRsPublisher())); return () -> Flowable.fromPublisher(publisher); }  @SuppressWarnings("unchecked") @Override PublisherStage<O> create(Engine engine, Stage.PublisherStage stage); }
FromPublisherStageFactory implements PublisherStageFactory<Stage.PublisherStage> { @SuppressWarnings("unchecked") @Override public <O> PublisherStage<O> create(Engine engine, Stage.PublisherStage stage) { Publisher<O> publisher = (Publisher<O>) Objects.requireNonNull(Objects.requireNonNull(stage.getRsPublisher())); return () -> Flowable.fromPublisher(publisher); }  @SuppressWarnings("unchecked") @Override PublisherStage<O> create(Engine engine, Stage.PublisherStage stage);  }