Strona główna / Streams / Stream.mapMulti()
Streams Średniozaawansowany

Stream.mapMulti()

Emituj zero lub więcej elementów na wejście bez tworzenia pośrednich strumieni.

Porównanie kodu
✕ Java 8 
stream.flatMap(order ->
    order.items().stream()
        .map(item -> new OrderItem(
            order.id(), item)
        )
);
✓ Java 16+ 
stream.<OrderItem>mapMulti(
    (order, downstream) -> {
        for (var item : order.items())
            downstream.accept(
                new OrderItem(order.id(), item));
    }
);
Widzisz problem z tym kodem? Daj nam znać.
Dlaczego nowoczesne podejście wygrywa
⚡

Mniej alokacji

Brak tworzenia pośredniego Stream na element.

🎯

Styl imperatywny

Używaj pętli i warunków bezpośrednio.

📐

Elastyczny

Emituj zero, jeden lub wiele elementów z pełną kontrolą.

Stare podejście
flatMap + List
Nowoczesne podejście
mapMulti()
Od JDK
16
Poziom trudności
Średniozaawansowany
Wsparcie JDK
Stream.mapMulti()
Dostępne

Szeroko dostępne od JDK 16 (marzec 2021)

Jak to działa

mapMulti() jest imperatywną alternatywą dla flatMap, która unika tworzenia pośrednich obiektów Stream dla każdego elementu. Jest bardziej efektywna gdy mapowanie produkuje małą liczbę elementów.

Powiązana dokumentacja
Stream.mapMulti() ↗
Dowód
Zobacz źródło dowodu ↗
Powiązane wzorce
Streams Średniozaawansowany

Stream.iterate() with predicate

Java 8
Stream.iterate(1, n -> n * 2)
    .limit(10)
    .forEach(System.out::println);
// can't stop at a condition
Java 9+
Stream.iterate(
    1,
    n -> n < 1000,
    n -> n * 2
).forEach(IO::println);
// stops when n >= 1000
Najedź, aby zobaczyć nową wersję ➜
JDK 9+ →
Streams Początkujący

Stream.ofNullable()

Java 8
Stream<String> s = val != null
    ? Stream.of(val)
    : Stream.empty();
Java 9+
Stream<String> s =
    Stream.ofNullable(val);
Najedź, aby zobaczyć nową wersję ➜
JDK 9+ →
Streams Zaawansowany

Stream gatherers

Java 8
// Sliding window: manual implementation
List<List<T>> windows = new ArrayList<>();
for (int i = 0; i <= list.size()-3; i++) {
    windows.add(
        list.subList(i, i + 3));
}
Java 24+
var windows = stream
    .gather(
        Gatherers.windowSliding(3)
    )
    .toList();
Najedź, aby zobaczyć nową wersję ➜
JDK 24+ →