Page History
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
final Materializer materializer = ActorMaterializer.create(system); //실행되는 엔진
final Source<Integer, NotUsed> source = Source.range(1, 100); //<방출요소,실행시 보조값>
//Scan을 사용하여 방출요소를 누적합함
final CompletionStage<Done> done =
source.scan( 0 , (acc, next) -> acc+next ).runForeach(i -> System.out.println(i), materializer);
done.thenRun(() -> System.out.println("Done runFirst2") ); |