Java : DoubleStream - API使用例

DoubleStream (Java SE 19 & JDK 19) の使用例まとめです。
だいたいのメソッドを網羅済みです。
API仕様のおともにどうぞ。

概要

順次および並列の集約操作をサポートするプリミティブdouble値要素のシーケンスです。これは、Streamに対してdoubleプリミティブ特殊化を行ったものです。

クラス構成

Stream のプリミティブ double 型版です。

final var stream = DoubleStream.of(1.0, 2.0, 3.0, 4.0);

stream.forEach(d -> {
    //0.5
    //1.0
    //1.5
    //2.0
    System.out.println(d / 2.0);
});

ストリームの基本的なことは下記の記事で解説していますので、そちらもご参照ください。

Java : ストリームの基本 (Stream)

メソッド

boolean allMatch (DoublePredicate predicate)

このストリームのすべての要素が指定された述語に一致するかどうかを返します。

final var predicate = new DoublePredicate() {
    @Override
    public boolean test(double value) {
        return value < 100.0;
    }
};

{
    final var stream = DoubleStream.of(1.0, 2.0, 3.0);

    final var ret = stream.allMatch(predicate);
    System.out.println(ret); // true
}
{
    final var stream = DoubleStream.of(1.0, 10.0, 100.0, 1000.0);

    final var ret = stream.allMatch(predicate);
    System.out.println(ret); // false
}

boolean anyMatch (DoublePredicate predicate)

このストリームのいずれかの要素が指定された述語に一致するかどうかを返します。

final var predicate = new DoublePredicate() {
    @Override
    public boolean test(double value) {
        return value < 100.0;
    }
};

{
    final var stream = DoubleStream.of(1.0, 2.0, 3.0);

    final var ret = stream.anyMatch(predicate);
    System.out.println(ret); // true
}
{
    final var stream = DoubleStream.of(1.0, 10.0, 100.0, 1000.0);

    final var ret = stream.anyMatch(predicate);
    System.out.println(ret); // true
}
{
    final var stream = DoubleStream.of(100.0, 1000.0, 10000.0);

    final var ret = stream.anyMatch(predicate);
    System.out.println(ret); // false
}

OptionalDouble average ()

このストリームの要素の算術平均を記述するOptionalDoubleを返します。このストリームが空の場合は空のOptionalを返します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0, 4.0);

final var ret = stream.average();
System.out.println(ret.orElseThrow()); // 2.5

final var ret = DoubleStream.empty().average();
System.out.println(ret.isEmpty()); // true

Stream<Double> boxed ()

このストリームの各要素をDoubleにボクシングした結果から構成されるStreamを返します。

final Stream<Double> stream = DoubleStream.of(1.23, 4.56, 7.89).boxed();

final var ret = stream.toList();
System.out.println(ret); // [1.23, 4.56, 7.89]

static DoubleStream.Builder builder ()

DoubleStreamのビルダーを返します。

final var builder = DoubleStream.builder();
builder.add(1.23).add(4.56).add(7.89);

final var stream = builder.build();

final var ret = stream.toArray();
System.out.println(Arrays.toString(ret)); // [1.23, 4.56, 7.89]

<R> R collect (Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R,R> combiner)

このストリームの要素に対して可変リダクション操作を実行します。

final var supplier = new Supplier<List<String>>() {
    @Override
    public List<String> get() {
        return new ArrayList<>();
    }
};

final var accumulator = new ObjDoubleConsumer<List<String>>() {
    @Override
    public void accept(List<String> list, double value) {
        list.add("d=" + value);
    }
};

final var combiner = new BiConsumer<List<String>, List<String>>() {
    @Override
    public void accept(List<String> list1, List<String> list2) {
        list1.addAll(list2);
    }
};

{
    final var stream = DoubleStream.of(1.23, 4.56, 7.89);

    final var ret = stream.collect(supplier, accumulator, combiner);
    System.out.println(ret); // [d=1.23, d=4.56, d=7.89]
}
{
    // combinerは並列ストリームで使われます。
    final var parallelStream = DoubleStream.of(1.23, 4.56, 7.89).parallel();
    System.out.println(parallelStream.isParallel()); // true

    final var ret = parallelStream.collect(supplier, accumulator, combiner);
    System.out.println(ret); // [d=1.23, d=4.56, d=7.89]
}

static DoubleStream concat (DoubleStream a, DoubleStream b)

最初のストリームの全要素と2番目のストリームの全要素を連結したものを要素に持つ、遅延連結ストリームを作成します。

final var stream1 = DoubleStream.of(1.0, 2.0, 3.0);
final var stream2 = DoubleStream.of(100.0, 200.0, 300.0);

System.out.println(stream1.isParallel()); // false
System.out.println(stream2.isParallel()); // false

final var concatStream = DoubleStream.concat(stream1, stream2);

System.out.println(concatStream.isParallel()); // false

final var ret = concatStream.toArray();
System.out.println(Arrays.toString(ret)); // [1.0, 2.0, 3.0, 100.0, 200.0, 300.0]

final var stream1 = DoubleStream.of(1.0, 2.0, 3.0).parallel();
final var stream2 = DoubleStream.of(100.0, 200.0, 300.0).parallel();

System.out.println(stream1.isParallel()); // true
System.out.println(stream2.isParallel()); // true

final var concatStream = DoubleStream.concat(stream1, stream2);

System.out.println(concatStream.isParallel()); // true

final var ret = concatStream.toArray();
System.out.println(Arrays.toString(ret)); // [1.0, 2.0, 3.0, 100.0, 200.0, 300.0]

long count ()

このストリームの要素の個数を返します。

final var stream = DoubleStream.of(1.23, 4.56, 7.89);
System.out.println(stream.count()); // 3

final var stream = DoubleStream.empty();
System.out.println(stream.count()); // 0

DoubleStream distinct ()

このストリームの重複を除いた要素から構成されるストリームを返します。

final var stream = DoubleStream.of(1.0, 2.0, 2.0, 3.0, 3.0, 3.0);

final var ret = stream.distinct().toArray();
System.out.println(Arrays.toString(ret)); // [1.0, 2.0, 3.0]

default DoubleStream dropWhile (DoublePredicate predicate)

このストリームが順序付けされている場合は、指定された述語に一致する要素の最長プレフィクスを削除した後に、このストリームの残りの要素で構成されるストリームを返します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0, 4.0, 5.0);

final var predicate = new DoublePredicate() {
    @Override
    public boolean test(double value) {
        return value != 3.0;
    }
};

final var ret = stream.dropWhile(predicate).toArray();
System.out.println(Arrays.toString(ret)); // [3.0, 4.0, 5.0]

final var stream = DoubleStream.of(-1.0, -2.0, -3.0, -4.0, -5.0);

final var ret = stream.dropWhile(d -> d != -4.0).toArray();
System.out.println(Arrays.toString(ret)); // [-4.0, -5.0]

static DoubleStream empty ()

空の順次DoubleStreamを返します。

final var stream = DoubleStream.empty();
System.out.println(stream.count()); // 0

final var stream = DoubleStream.empty();
final var array = stream.toArray();
System.out.println(Arrays.toString(array)); // []

DoubleStream filter (DoublePredicate predicate)

このストリームの要素のうち、指定された述語に一致するものから構成されるストリームを返します。

final var stream = DoubleStream.of(1.0, 10.0, 100.0, 1000.0, 10000.0);

final var predicate = new DoublePredicate() {
    @Override
    public boolean test(double value) {
        return value < 1000.0;
    }
};

final var ret = stream.filter(predicate).toArray();
System.out.println(Arrays.toString(ret)); // [1.0, 10.0, 100.0]

final var stream = DoubleStream.of(1.0, 10.0, 100.0, 1000.0, 10000.0);

final var ret = stream.filter(v -> v > 100.0).toArray();
System.out.println(Arrays.toString(ret)); // [1000.0, 10000.0]

OptionalDouble findAny ()

ストリームの一部の要素を記述するOptionalDoubleを返します。ストリームが空の場合は空のOptionalDoubleを返します。

int count1 = 0;
int count2 = 0;
int count3 = 0;

for (int i = 0; i < 1000; i++) {

    final var stream = DoubleStream.of(1.0, 2.0, 3.0).parallel();
    System.out.println(stream.isParallel()); // true

    // 1.0 or 2.0 or 3.0
    final var ret = stream.findAny();
    switch (Double.toString(ret.orElseThrow())) {
        case "1.0" -> count1++;
        case "2.0" -> count2++;
        case "3.0" -> count3++;
    }
}

System.out.println("count1 : " + count1);
System.out.println("count2 : " + count2);
System.out.println("count3 : " + count3);

// 結果
// ↓
//count1 : 85
//count2 : 913
//count3 : 2

final var stream = DoubleStream.empty();

final var ret = stream.findAny();
System.out.println(ret.isEmpty()); // true

OptionalDouble findFirst ()

このストリームの最初の要素を記述するOptionalDoubleを返します。ストリームが空の場合は空のOptionalDoubleを返します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0);

final var ret = stream.findFirst();
System.out.println(ret.orElseThrow()); // 1.0

// findAny と違い、parallelでも最初の要素を返します。
final var stream = DoubleStream.of(1.0, 2.0, 3.0).parallel();
System.out.println(stream.isParallel()); // true

final var ret = stream.findFirst();
System.out.println(ret.orElseThrow()); // 1.0

int count1 = 0;
int count2 = 0;
int count3 = 0;

for (int i = 0; i < 1000; i++) {

    // ただし、unordered かつ parallel の場合は、どの値が返されるかは決まりません。
    final var stream = DoubleStream.of(1.0, 2.0, 3.0).unordered().parallel();

    // 1.0 or 2.0 or 3.0
    final var ret = stream.findFirst();
    switch (Double.toString(ret.orElseThrow())) {
        case "1.0" -> count1++;
        case "2.0" -> count2++;
        case "3.0" -> count3++;
    }
}

System.out.println("count1 : " + count1);
System.out.println("count2 : " + count2);
System.out.println("count3 : " + count3);

// 結果
// ↓
//count1 : 52
//count2 : 946
//count3 : 2

final var stream = DoubleStream.empty();

final var ret = stream.findFirst();
System.out.println(ret.isEmpty()); // true

DoubleStream flatMap (DoubleFunction<? extends DoubleStream> mapper)

このストリームの各要素をマップされたストリーム(指定されたマッピング関数を各要素に適用することで得られる)の内容で置き換えた結果から成るストリームを返します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0);

final var mapper = new DoubleFunction<DoubleStream>() {
    @Override
    public DoubleStream apply(double value) {
        return DoubleStream.of(value, value + 0.1, value + 0.2);
    }
};

final var ret = stream.flatMap(mapper).toArray();
System.out.println(Arrays.toString(ret)); // [1.0, 1.1, 1.2, 2.0, 2.1, 2.2, 3.0, 3.1, 3.2]

void forEach (DoubleConsumer action)

このストリームの各要素に対してアクションを実行します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0);

final var action = new DoubleConsumer() {
    @Override
    public void accept(double value) {
        System.out.println(value);
    }
};

//1.0
//2.0
//3.0
stream.forEach(action);

// ラムダ式を使う例
final var stream = DoubleStream.of(1.0, 2.0, 3.0);

stream.forEach(v -> {
    //1.0
    //2.0
    //3.0
    System.out.println(v);
});

// メソッド参照を使う例
final var stream = DoubleStream.of(1.0, 2.0, 3.0);

//1.0
//2.0
//3.0
stream.forEach(System.out::println);

final var stream = DoubleStream.of(1.0, 2.0, 3.0).parallel();
System.out.println(stream.isParallel()); // true

// 並列ストリームは呼び出し順は保証されません。

//2.0
//3.0
//1.0
stream.forEach(System.out::println);

void forEachOrdered (DoubleConsumer action)

このストリームの各要素に対してアクションを実行します。検出順が定義されたストリームでは、各要素が検出順に処理されることが保証されます。

final var stream = DoubleStream.of(1.0, 2.0, 3.0);

final var action = new DoubleConsumer() {
    @Override
    public void accept(double value) {
        System.out.println(value);
    }
};

//1.0
//2.0
//3.0
stream.forEachOrdered(action);

final var stream = DoubleStream.of(1.0, 2.0, 3.0).parallel();
System.out.println(stream.isParallel()); // true

// 並列ストリームでも呼び出し順が保証されます。

//1.0
//2.0
//3.0
stream.forEachOrdered(System.out::println);

static DoubleStream generate (DoubleSupplier s)

指定されたDoubleSupplierによって生成される要素を含む、順序付けされていない無限順次ストリームを返します。

final var supplier = new DoubleSupplier() {
    double count = 0.0;

    @Override
    public double getAsDouble() {
        count += 1.0;
        return count;
    }
};

final var stream = DoubleStream.generate(supplier);

// limitをつけないと無限に続くのでご注意ください。
final var ret = stream.limit(10).toArray();
System.out.println(Arrays.toString(ret)); // [1.0, 2.0, 3.0, 4.0, 5.0, 6.0, 7.0, 8.0, 9.0, 10.0]

static DoubleStream iterate (double seed, DoublePredicate hasNext, DoubleUnaryOperator next)

指定されたnext関数を初期要素に反復適用することによって生成され、与えられたhasNext述語を満たすことを条件とする、順次順序付けされたDoubleStreamを返します。

final var hasNext = new DoublePredicate() {
    @Override
    public boolean test(double value) {
        return value < 100.0;
    }
};

final var next = new DoubleUnaryOperator() {
    @Override
    public double applyAsDouble(double operand) {
        return operand * 2;
    }
};

final var stream = DoubleStream.iterate(1.0, hasNext, next);

final var ret = stream.toArray();
System.out.println(Arrays.toString(ret)); // [1.0, 2.0, 4.0, 8.0, 16.0, 32.0, 64.0]

static DoubleStream iterate (double seed, DoubleUnaryOperator f)

初期要素seedに関数fを繰り返し適用することで生成される、順序付けされた無限順次DoubleStreamを返します(seed、f(seed)、f(f(seed))、といった要素から成るStreamが生成される)。

final var next = new DoubleUnaryOperator() {
    @Override
    public double applyAsDouble(double operand) {
        return operand * 2;
    }
};

final var stream = DoubleStream.iterate(1.0, next);

// limitをつけないと無限に続くのでご注意ください。
final var ret = stream.limit(10).toArray();

// [1.0, 2.0, 4.0, 8.0, 16.0, 32.0, 64.0, 128.0, 256.0, 512.0]
System.out.println(Arrays.toString(ret));

DoubleStream limit (long maxSize)

このストリームの要素をmaxSize以内の長さに切り詰めた結果から成るストリームを返します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0, 4.0, 5.0);

final var ret = stream.limit(3).toArray();
System.out.println(Arrays.toString(ret)); // [1.0, 2.0, 3.0]

DoubleStream map (DoubleUnaryOperator mapper)

このストリームの要素に指定された関数を適用した結果から構成されるストリームを返します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0);

final var mapper = new DoubleUnaryOperator() {
    @Override
    public double applyAsDouble(double operand) {
        return operand * 2;
    }
};

final var ret = stream.map(mapper).toArray();
System.out.println(Arrays.toString(ret)); // [2.0, 4.0, 6.0]

final var stream = DoubleStream.of(1.0, 3.0, 5.0);

final var ret = stream.map(v -> v * 100).toArray();
System.out.println(Arrays.toString(ret)); // [100.0, 300.0, 500.0]

default DoubleStream mapMulti (DoubleStream.DoubleMapMultiConsumer mapper)

このストリームの各要素を複数の要素(特にゼロ個以上の要素)で置き換えた結果で構成されるストリームを返します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0);

final var mapper = new DoubleStream.DoubleMapMultiConsumer() {
    @Override
    public void accept(double value, DoubleConsumer ic) {
        ic.accept(value);
        ic.accept(value + 0.1);
        ic.accept(value + 0.2);
    }
};

final var ret = stream.mapMulti(mapper).toArray();
System.out.println(Arrays.toString(ret)); // [1.0, 1.1, 1.2, 2.0, 2.1, 2.2, 3.0, 3.1, 3.2]

IntStream mapToInt (DoubleToIntFunction mapper)

このストリームの要素に指定された関数を適用した結果から構成されるIntStreamを返します。

final var stream = DoubleStream.of(1.0, 1.2, 1.4, 1.6, 1.8, 2.0);

final var mapper = new DoubleToIntFunction() {
    @Override
    public int applyAsInt(double value) {
        return (int) Math.round(value);
    }
};

final var ret = stream.mapToInt(mapper).toArray();
System.out.println(Arrays.toString(ret)); // [1, 1, 1, 2, 2, 2]

LongStream mapToLong (DoubleToLongFunction mapper)

このストリームの要素に指定された関数を適用した結果から構成されるLongStreamを返します。

final var stream = DoubleStream.of(1.0, 1.2, 1.4, 1.6, 1.8, 2.0);

final var mapper = new DoubleToLongFunction() {
    @Override
    public long applyAsLong(double value) {
        return Math.round(value);
    }
};

final var ret = stream.mapToLong(mapper).toArray();
System.out.println(Arrays.toString(ret)); // [1, 1, 1, 2, 2, 2]

<U> Stream<U> mapToObj (DoubleFunction<? extends U> mapper)

指定された関数をこのストリームの要素に適用した結果から構成される、オブジェクト値のStreamを返します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0);

final var mapper = new DoubleFunction<String>() {
    @Override
    public String apply(double value) {
        return "num=" + value;
    }
};

final var ret = stream.mapToObj(mapper).toList();
System.out.println(ret); // [num=1.0, num=2.0, num=3.0]

OptionalDouble max ()

このストリームの最大要素を記述するOptionalDoubleまたは空のOptionalDouble(このストリームが空の場合)を返します。

final var stream = DoubleStream.of(10.0, 5.0, 100.0, 30.0);

final var max = stream.max();
System.out.println(max.orElseThrow()); // 100.0

final var stream = DoubleStream.empty();

final var max = stream.max();
System.out.println(max.isEmpty()); // true

OptionalDouble min ()

このストリームの最小要素を記述するOptionalDoubleまたは空のOptionalDouble(このストリームが空の場合)を返します。

final var stream = DoubleStream.of(10.0, 5.0, 100.0, 30.0);

final var min = stream.min();
System.out.println(min.orElseThrow()); // 5.0

final var stream = DoubleStream.empty();

final var min = stream.min();
System.out.println(min.isEmpty()); // true

boolean noneMatch (DoublePredicate predicate)

指定された述語に一致する要素がこのストリーム内に存在しないかどうかを返します。

final var predicate = new DoublePredicate() {
    @Override
    public boolean test(double value) {
        return value < 100.0;
    }
};

{
    final var stream = DoubleStream.of(1.0, 2.0, 3.0);

    final var ret = stream.noneMatch(predicate);
    System.out.println(ret); // false
}
{
    final var stream = DoubleStream.of(1.0, 10.0, 100.0, 1000.0);

    final var ret = stream.noneMatch(predicate);
    System.out.println(ret); // false
}
{
    final var stream = DoubleStream.of(100.0, 1000.0, 10000.0);

    final var ret = stream.noneMatch(predicate);
    System.out.println(ret); // true
}

static DoubleStream of (double t)

単一要素を含む順次DoubleStreamを返します。

final var stream = DoubleStream.of(1.23);

final var ret = stream.toArray();
System.out.println(Arrays.toString(ret)); // [1.23]

final var stream = DoubleStream.of(-4.56);

final var ret = stream.toArray();
System.out.println(Arrays.toString(ret)); // [-4.56]

static DoubleStream of (double... values)

指定された値を要素に持つ、順序付けされた順次ストリームを返します。

final var stream = DoubleStream.of(0.0, 2.0, 4.0, 6.0);

final var ret = stream.toArray();
System.out.println(Arrays.toString(ret)); // [0.0, 2.0, 4.0, 6.0]

DoubleStream peek (DoubleConsumer action)

このストリームの要素から成るストリームを返すほか、その結果のストリームから消費される各要素に対し、指定されたアクションを実行します。

peek は中間操作です。
よって、peek のあとに toArray などの終端操作を実行できます。

final var stream = DoubleStream.of(1.0, 2.0, 3.0);

final var action = new DoubleConsumer() {
    @Override
    public void accept(double value) {
        System.out.println(value * 100);
    }
};

//100.0
//200.0
//300.0
final var array = stream.peek(action).toArray();

System.out.println(Arrays.toString(array)); // [1.0, 2.0, 3.0]

double reduce (double identity, DoubleBinaryOperator op)

指定された単位元の値と結合的な累積関数を使ってこのストリームの要素に対してリダクションを実行し、リデュースされた値を返します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0, 4.0);
final var identity = 0.0;

final var accumulator = new DoubleBinaryOperator() {
    @Override
    public double applyAsDouble(double left, double right) {
        if (identity == left) {
            return right;
        }

        return left + right;
    }
};

// 結果として、要素の合計となります。
final var ret = stream.reduce(identity, accumulator);
System.out.println(ret); // 10.0

final var stream = DoubleStream.empty();
final var identity = 0.0;

final var ret = stream.reduce(identity, (left, right) -> {
    if (identity == left) {
        return right;
    }

    return left + right;
});

System.out.println(ret); // 0.0

OptionalDouble reduce (DoubleBinaryOperator op)

結合的累積関数を使用して、このストリームの要素に対してリダクションを実行し、リダクションされた値を記述するOptionalDoubleを返します(ある場合)。

final var stream = DoubleStream.of(1.0, 2.0, 3.0, 4.0);

final var accumulator = new DoubleBinaryOperator() {
    @Override
    public double applyAsDouble(double left, double right) {
        return left + right;
    }
};

// 結果として、要素の合計となります。
final var ret = stream.reduce(accumulator);
System.out.println(ret.orElseThrow()); // 10.0

final var stream = DoubleStream.empty();

final var ret = stream.reduce((left, right) -> left + right);
System.out.println(ret.isEmpty()); // true

DoubleStream skip (long n)

このストリームの最初のn個の要素を破棄した残りの要素で構成されるストリームを返します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0, 4.0, 5.0, 6.0, 7.0);

final var ret = stream.skip(4).toArray();
System.out.println(Arrays.toString(ret)); // [5.0, 6.0, 7.0]

DoubleStream sorted ()

このストリームの要素で構成されるストリームをソートされた順序で返します。

final var stream = DoubleStream.of(5.0, 3.0, 2.0, 4.0, 1.0);

final var ret = stream.sorted().toArray();
System.out.println(Arrays.toString(ret)); // [1.0, 2.0, 3.0, 4.0, 5.0]

final var stream = DoubleStream.of(5.0, 3.0, 2.0, 4.0, 1.0).parallel();
System.out.println(stream.isParallel()); // true

final var ret = stream.sorted().toArray();
System.out.println(Arrays.toString(ret)); // [1.0, 2.0, 3.0, 4.0, 5.0]

double sum ()

このストリーム内の要素の合計を返します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0, 4.0, 5.0);
System.out.println(stream.sum()); // 15.0

final var stream = DoubleStream.of(-10.0, -20.0, -30.0);
System.out.println(stream.sum()); // -60.0

DoubleSummaryStatistics summaryStatistics ()

このストリームの要素に関する各種のサマリー・データを記述するDoubleSummaryStatisticsを返します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0, 4.0, 5.0);

final var ret = stream.summaryStatistics();

// DoubleSummaryStatistics{count=5, sum=15.000000, min=1.000000, average=3.000000, max=5.000000}
System.out.println(ret);

default DoubleStream takeWhile (DoublePredicate predicate)

このストリームが順序付けされている場合、指定された述語に一致するこのストリームから取得された要素の最長プレフィクスからなるストリームを返します。

final var stream = DoubleStream.of(1.0, 2.0, 3.0, 4.0, 5.0);

final var predicate = new DoublePredicate() {
    @Override
    public boolean test(double value) {
        return value != 4.0;
    }
};

final var ret = stream.takeWhile(predicate).toArray();
System.out.println(Arrays.toString(ret)); // [1.0, 2.0, 3.0]

final var stream = DoubleStream.of(-1.0, -2.0, -3.0, -4.0, -5.0);

final var ret = stream.takeWhile(i -> i != -3.0).toArray();
System.out.println(Arrays.toString(ret)); // [-1.0, -2.0]

double[] toArray ()

このストリームの要素を含む配列を返します。

final var stream = DoubleStream.of(1.23, 4.56, 7.89);
final double[] ret = stream.toArray();

System.out.println(Arrays.toString(ret)); // [1.23, 4.56, 7.89]

BaseStreamで宣言されたメソッド

close, isParallel, iterator, onClose, parallel, sequential, spliterator, unordered

「Java API 使用例 : BaseStream」をご参照ください。

API 使用例