@Test(expected = NullPointerException.class) public void createWithoutStage() { factory.create(null, null); }
@Override public <I, O> ProcessingStage<I, O> create(Engine engine, Stage.FlatMapIterable stage) { Function<I, Iterable<O>> mapper = Casts.cast(stage.getMapper()); return new FlatMapIterable<>(mapper); }
FlatMapIterableStageFactory implements ProcessingStageFactory<Stage.FlatMapIterable> { @Override public <I, O> ProcessingStage<I, O> create(Engine engine, Stage.FlatMapIterable stage) { Function<I, Iterable<O>> mapper = Casts.cast(stage.getMapper()); return new FlatMapIterable<>(mapper); } }
FlatMapIterableStageFactory implements ProcessingStageFactory<Stage.FlatMapIterable> { @Override public <I, O> ProcessingStage<I, O> create(Engine engine, Stage.FlatMapIterable stage) { Function<I, Iterable<O>> mapper = Casts.cast(stage.getMapper()); return new FlatMapIterable<>(mapper); }  }
FlatMapIterableStageFactory implements ProcessingStageFactory<Stage.FlatMapIterable> { @Override public <I, O> ProcessingStage<I, O> create(Engine engine, Stage.FlatMapIterable stage) { Function<I, Iterable<O>> mapper = Casts.cast(stage.getMapper()); return new FlatMapIterable<>(mapper); }  @Override ProcessingStage<I, O> create(Engine engine, Stage.FlatMapIterable stage); }
FlatMapIterableStageFactory implements ProcessingStageFactory<Stage.FlatMapIterable> { @Override public <I, O> ProcessingStage<I, O> create(Engine engine, Stage.FlatMapIterable stage) { Function<I, Iterable<O>> mapper = Casts.cast(stage.getMapper()); return new FlatMapIterable<>(mapper); }  @Override ProcessingStage<I, O> create(Engine engine, Stage.FlatMapIterable stage);  }