raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

use correct Source import

Browse source
This commit is contained in:
David Mischke 2018-07-27 17:51:00 +02:00
parent f543f69c93
commit 2737caf8fb
3 changed files with 30 additions and 49 deletions
Download patch file Download diff file Expand all files Collapse all files

27
akka-docs/src/test/java/jdocs/stream/operators/SourceDocExamples.java
View file

@ -5,11 +5,13 @@
package jdocs.stream.operators;
//#imports
//#range-imports
import akka.NotUsed;
import akka.actor.ActorSystem;
import akka.stream.ActorMaterializer;
import akka.stream.Materializer;
import akka.stream.javadsl.Source;
//#range-imports
import java.util.Arrays;
@ -32,4 +34,29 @@ public class SourceDocExamples {
//#source-from-example
}
static void rangeExample() {
final ActorSystem system = ActorSystem.create("Source");
final Materializer materializer = ActorMaterializer.create(system);
//#range
Source<Integer, NotUsed> source = Source.range(1, 100);
//#range
//#range
Source<Integer, NotUsed> sourceStepFive = Source.range(1, 100, 5);
//#range
//#range
Source<Integer, NotUsed> sourceStepNegative = Source.range(100, 1, -1);
//#range
//#run-range
source.runForeach(i -> System.out.println(i), materializer);
//#run-range
}
}