Source.single

Stream a single object

Source operators

def single[T](element: T): Source[T, NotUsed]

Description

Stream a single object

Examples

Scala

copysourceimport akka.stream._

val s: Future[immutable.Seq[Int]] = Source.single(1).runWith(Sink.seq)
s.foreach(list => println(s"Collected elements: $list")) // prints: Collected elements: List(1)

Java

copysourceimport akka.stream.*;

CompletionStage<List<String>> future = Source.single("A").runWith(Sink.seq(), materializer);
CompletableFuture<List<String>> completableFuture = future.toCompletableFuture();
completableFuture.thenAccept(result -> System.out.printf("collected elements: %s\n", result));
// result list will contain exactly one element "A"