Leniwe pobieranie i filtrowanie

Prawdziwa wartość LazyList ujawnia się podczas jego pobierania. Operacje takie jak take, filter i map pozostają leniwe, obliczając tylko te komórki, które ostatecznie wymusisz.

W tej lekcji omówimy najważniejsze transformatory oraz sposób zatrzymywania leniwości we właściwym momencie.

take(n) zwraca LazyList zawierający co najwyżej pierwszych n elementów, który sam nadal jest leniwy. Nic nie zostanie obliczone, dopóki nie wymusisz wyniku.

To bezpieczny sposób na ograniczenie nieskończonego strumienia.

takeWhile(p) zwraca elementy tak długo, jak predykat jest spełniony, a następnie zatrzymuje się przy pierwszym niespełnieniu.

W przypadku nieskończonego strumienia jest to przejrzysty warunek zakończenia, który nie wymaga znajomości liczby elementów.

drop(n) pomija pierwszych n elementów, a dropWhile(p) pomija elementy tak długo, jak predykat jest spełniony. Obie metody zwracają leniwą pozostałą część.

Używaj ich do przejścia do wybranego miejsca w strumieniu przed pobraniem fragmentu.

filter na LazyList jest leniwe: testuje elementy dopiero wtedy, gdy pobiera je konsument znajdujący się dalej w potoku.

W połączeniu z take przetwarzasz dokładnie tyle elementów źródłowych, ile potrzeba do zaspokojenia zapotrzebowania — ani jednego więcej.

Dodaj instrukcję print wewnątrz predykatu, aby zobaczyć, jak niewiele elementów zostaje sprawdzonych. Filtrowanie działa tylko do momentu spełnienia warunku take.

Uruchom ten kod: liczba wierszy z napisem "check" pokazuje ewaluację sterowaną zapotrzebowaniem, a nie przetwarzanie całego strumienia.

Możesz łączyć transformatory — cały potok pozostaje leniwy i jest łączony dla poszczególnych elementów. Każdy element źródłowy przechodzi przez map, a następnie filter dopiero wtedy, gdy zostanie pobrany.

Nie są tworzone pośrednie pełne kolekcje.

find(p) zwraca pierwszy pasujący element jako Option, wymuszając obliczenia tylko do tego elementu. Doskonale nadaje się do przeszukiwania nieskończonego strumienia.

Po znalezieniu dopasowania ewaluacja natychmiast się zatrzymuje.

headOption bezpiecznie sprawdza pierwszy element, a exists(p) wymusza obliczenia tylko do znalezienia dopasowania (lub trwa bez końca, jeśli go nie ma). Używaj exists na nieskończonych strumieniach tylko wtedy, gdy dopasowanie jest gwarantowane.

Obie metody zatrzymują się tak wcześnie, jak to możliwe.

Len iwe transformatory opisują pracę, a operacja terminalna ją wymusza. toList, foreach, sum i foldLeft konsumują (ograniczony) strumień i tworzą konkretną wartość.

Zawsze ogranicz nieskończony strumień przed operacją terminalną, która wymaga przetworzenia wszystkich jego elementów.

Element filter, który niczego nie dopasowuje, zamienia ograniczone take w nieskończone wyszukiwanie. LazyList.from(1).filter(_ < 0).take(1) zawiesi się na zawsze.

Upewnij się, że predykaty mogą zostać spełnione, albo połącz filtrowanie z takeWhile, aby zagwarantować zakończenie.

take, takeWhile, drop, filter i map pozostają leniwe i są łączone dla poszczególnych elementów; find, exists i headOption zatrzymują się wcześnie, a operacje terminalne, takie jak toList i sum, wymuszają wynik.

Chroń się przed filtrami, których nie da się spełnić, na nieskończonych strumieniach. Potrafisz już z przekonaniem generować i konsumować leniwe sekwencje.