@Test public void createWithoutFunction() { assertThrows(NullPointerException.class, () -> 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 () -> Multi.createFrom().iterable(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 () -> Multi.createFrom().iterable(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 () -> Multi.createFrom().iterable(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 () -> Multi.createFrom().iterable(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 () -> Multi.createFrom().iterable(elements); }  @SuppressWarnings("unchecked") @Override PublisherStage<O> create(Engine engine, Stage.Of stage);  }