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