Adding example of cancelled operator (#29749)

Co-authored-by: Arnout Engelen <github@bzzt.net>
Co-authored-by: Renato Cavalcanti <renato@cavalcanti.be>
This commit is contained in:
Muskan Gupta 2020-10-20 17:13:26 +05:30 committed by GitHub
parent 9c200e3a04
commit 432d94d5a4
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 40 additions and 2 deletions

View file

@ -114,6 +114,14 @@ public class SinkDocExamples {
// #fold
}
static NotUsed cancelledExample() {
// #cancelled
Source<Integer, NotUsed> source = Source.range(1, 5);
NotUsed sum = source.runWith(Sink.cancelled(), system);
return sum;
// #cancelled
}
static void headOptionExample() {
// #headoption
Source<Integer, NotUsed> source = Source.empty();