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

#19719 add ThrottleMode Java API

Browse source
This commit is contained in:
Martynas Mickevičius 2016-02-10 10:17:02 +02:00
parent 429ec5556d
commit 0fc3fceb8b
2 changed files with 21 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

12
akka-stream-tests/src/test/java/akka/stream/javadsl/SourceTest.java
View file

@ -716,4 +716,16 @@ public class SourceTest extends StreamTest {
final Source<Integer, NotUsed> f =
Source.single(42).withAttributes(Attributes.name("")).addAttributes(Attributes.asyncBoundary()).named("");
}
@Test
public void mustBeAbleToUseThrottle() throws Exception {
Integer result =
Source.from(Arrays.asList(0, 1, 2))
.throttle(10, FiniteDuration.create(1, TimeUnit.SECONDS), 10, ThrottleMode.shaping())
.throttle(10, FiniteDuration.create(1, TimeUnit.SECONDS), 10, ThrottleMode.enforcing())
.runWith(Sink.head(), materializer)
.toCompletableFuture().get(3, TimeUnit.SECONDS);
assertEquals((Object) 0, result);
}
}