Sink.last

Materializes into a Future CompletionStage which will complete with the last value emitted when the stream completes.

Sink operators

def last[T]: Sink[T, Future[T]]

Description

Materializes into a Future CompletionStage which will complete with the last value emitted when the stream completes. If the stream completes with no elements the Future CompletionStage is failed.

Example

Scala

copysourceval source = Source(1 to 10)
val result: Future[Int] = source.runWith(Sink.last)
result.map(println)
// 10

Java

copysourceSource<Integer, NotUsed> source = Source.from(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10));
CompletionStage<Integer> result = source.runWith(Sink.last(), materializer);
result.thenAccept(System.out::println);
// 10