Sink.last
Materializes into a Future
which will complete with the last value emitted when the stream completes.
Signature¶
Description¶
Materializes into a Future
which will complete with the last value emitted when the stream completes. If the stream completes with no elements the Future
is failed.
Example¶
sourceval source = Source(1 to 10)
val result: Future[Int] = source.runWith(Sink.last)
result.map(println)
// 10
sourceSource<Integer, NotUsed> source = Source.from(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10));
CompletionStage<Integer> result = source.runWith(Sink.last(), system);
result.thenAccept(System.out::println);
// 10
Reactive Streams semantics¶
cancels never
backpressures never
1.1.3