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

Docs: use RestartSettings (#29788)

Browse source
This commit is contained in:
Enno Runne 2020-11-16 09:24:56 +01:00 • committed by GitHub
parent 3328d60244
commit d253c6402d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-docs/src/test/java/jdocs/stream/operators/source/Restart.java
View file

@ -79,7 +79,8 @@ public class Restart {
Source.tick(Duration.ofSeconds(1), Duration.ofSeconds(1), "tick").take(3); Source.tick(Duration.ofSeconds(1), Duration.ofSeconds(1), "tick").take(3);
Source<String, NotUsed> forever = Source<String, NotUsed> forever =
RestartSource.onFailuresWithBackoff( RestartSource.onFailuresWithBackoff(
Duration.ofSeconds(1), Duration.ofSeconds(10), 0.1, () -> finiteSource); RestartSettings.create(Duration.ofSeconds(1), Duration.ofSeconds(10), 0.1),
() -> finiteSource);
forever.runWith(Sink.foreach(System.out::println), system); forever.runWith(Sink.foreach(System.out::println), system);
// prints // prints
// tick // tick