Source.single

Stream a single object once.

Source operators

Signature

Source.singleSource.single

Description

Stream a single object once and complete after thereafter.

See also:

• repeat Stream a single object repeatedly.
• tick A periodical repetition of an arbitrary object.
• cycle Stream iterator in cycled manner.

Examples

Scala

copysourceimport org.apache.pekko.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 org.apache.pekko.stream.*;
CompletionStage<List<String>> future = Source.single("A").runWith(Sink.seq(), system);
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"

Reactive Streams semantics