fromJavaStream

Stream the values from a Java 8 Stream, requesting the next value when there is demand.

Source operators

Signature

StreamConverters.fromJavaStreamStreamConverters.fromJavaStream

Description

Stream the values from a Java 8 Stream, requesting the next value when there is demand. The iterator will be created anew for each materialization, which is the reason the method factory takes a function Creator rather than an Stream directly.

You can use Source.async to create asynchronous boundaries between synchronous java stream and the rest of flow.

Example

Scala

copysourceSource.fromJavaStream(() => IntStream.rangeClosed(1, 3)).runForeach(println)
// could print
// 1
// 2
// 3

Java

copysourceSource.fromJavaStream(() -> IntStream.rangeClosed(1, 3))
    .runForeach(System.out::println, system);
// could print
// 1
// 2
// 3

Reactive Streams semantics