Source.fromArray
Stream the values of an array
.
Signature¶
Description¶
Stream the values of a Java array
.
Examples¶
sourceimport org.apache.pekko.Done;
import org.apache.pekko.NotUsed;
import org.apache.pekko.actor.ActorSystem;
import org.apache.pekko.actor.testkit.typed.javadsl.ManualTime;
import org.apache.pekko.actor.testkit.typed.javadsl.TestKitJunitResource;
import org.apache.pekko.stream.javadsl.Source;
import org.apache.pekko.actor.ActorRef;
import org.apache.pekko.stream.OverflowStrategy;
import org.apache.pekko.stream.CompletionStrategy;
import org.apache.pekko.stream.javadsl.Sink;
import org.apache.pekko.testkit.TestProbe;
import org.apache.pekko.stream.javadsl.RunnableGraph;
import java.util.concurrent.CompletableFuture;
import java.util.Arrays;
import java.util.Optional;
Source<String, NotUsed> words = Source.fromArray("Hello world".split("\\s"));
words.runForeach(System.out::println, system);
Reactive Streams semantics¶
emits the next value of the array
completes when the last element of the seq has been emitted
1.1.3