@Test(expected = NullPointerException.class) public void createWithoutFunction() { factory.create(null, () -> null); }
@SuppressWarnings("unchecked") @Override public <O> PublisherStage<O> create(Engine engine, Stage.Of stage) { Iterable<O> elements = (Iterable<O>) Objects.requireNonNull(Objects.requireNonNull(stage).getElements()); return () -> Flowable.fromIterable(elements); }
FromIterableStageFactory implements PublisherStageFactory<Stage.Of> { @SuppressWarnings("unchecked") @Override public <O> PublisherStage<O> create(Engine engine, Stage.Of stage) { Iterable<O> elements = (Iterable<O>) Objects.requireNonNull(Objects.requireNonNull(stage).getElements()); return () -> Flowable.fromIterable(elements); } }
FromIterableStageFactory implements PublisherStageFactory<Stage.Of> { @SuppressWarnings("unchecked") @Override public <O> PublisherStage<O> create(Engine engine, Stage.Of stage) { Iterable<O> elements = (Iterable<O>) Objects.requireNonNull(Objects.requireNonNull(stage).getElements()); return () -> Flowable.fromIterable(elements); }  }
FromIterableStageFactory implements PublisherStageFactory<Stage.Of> { @SuppressWarnings("unchecked") @Override public <O> PublisherStage<O> create(Engine engine, Stage.Of stage) { Iterable<O> elements = (Iterable<O>) Objects.requireNonNull(Objects.requireNonNull(stage).getElements()); return () -> Flowable.fromIterable(elements); }  @SuppressWarnings("unchecked") @Override PublisherStage<O> create(Engine engine, Stage.Of stage); }
FromIterableStageFactory implements PublisherStageFactory<Stage.Of> { @SuppressWarnings("unchecked") @Override public <O> PublisherStage<O> create(Engine engine, Stage.Of stage) { Iterable<O> elements = (Iterable<O>) Objects.requireNonNull(Objects.requireNonNull(stage).getElements()); return () -> Flowable.fromIterable(elements); }  @SuppressWarnings("unchecked") @Override PublisherStage<O> create(Engine engine, Stage.Of stage);  }