Prendre et filtrer paresseusement

La véritable valeur d’une LazyList apparaît lorsque vous la consommez. Les opérations comme take, filter et map restent paresseuses et ne calculent que les cellules que vous finissez par forcer.

Cette leçon présente les principaux transformateurs et la manière d’arrêter la paresse au bon moment.

take(n) renvoie une LazyList contenant au plus les n premiers éléments, qui reste elle-même paresseuse. Rien n’est calculé avant que vous ne forciez le résultat.

C’est la manière sûre de limiter un flux infini.

takeWhile(p) fournit les éléments tant que le prédicat est vérifié, puis s’arrête au premier échec.

Sur un flux infini, c’est une condition d’arrêt claire qui ne nécessite pas de connaître un nombre d’éléments.

drop(n) ignore les n premiers éléments ; dropWhile(p) ignore les éléments tant que le prédicat est vérifié. Les deux renvoient le reste de manière paresseuse.

Utilisez-les pour avancer dans un flux avant d’en prendre une portion.

filter est paresseux sur une LazyList : il ne teste les éléments que lorsque le consommateur en aval les demande.

Associé à take, il traite exactement assez d’éléments sources pour satisfaire la demande, et pas davantage.

Ajoutez une instruction d’affichage dans le prédicat pour observer le petit nombre d’éléments testés. Le filtre ne s’exécute que jusqu’à ce que take soit satisfait.

Exécutez ceci : le nombre de lignes « check » montre une évaluation pilotée par la demande, et non le parcours du flux entier.

Vous pouvez enchaîner les transformateurs ; tout le pipeline reste paresseux et se fusionne élément par élément. Chaque élément source passe par map puis filter uniquement lorsqu’il est extrait.

Aucune collection intermédiaire complète n’est construite.

find(p) renvoie le premier élément correspondant sous forme d’Option, en ne forçant que les éléments jusqu’à celui-ci. C’est idéal pour rechercher dans un flux infini.

Dès qu’une correspondance est trouvée, l’évaluation s’arrête immédiatement.

headOption consulte le premier élément en toute sécurité ; exists(p) force les éléments jusqu’à trouver une correspondance, ou indéfiniment si aucune n’existe. Utilisez exists sur des flux infinis uniquement lorsqu’une correspondance est garantie.

Les deux s’arrêtent dès que possible.

Les transformateurs paresseux décrivent le travail ; une opération terminale le force. toList, foreach, sum et foldLeft consomment le flux borné et produisent une valeur concrète.

Limitez toujours un flux infini avant d’utiliser une opération terminale qui doit le parcourir entièrement.

Un filter qui ne trouve aucune correspondance transforme un take borné en recherche infinie. LazyList.from(1).filter(_ < 0).take(1) reste bloqué indéfiniment.

Assurez-vous que les prédicats peuvent être satisfaits, ou associez le filtrage à takeWhile pour garantir la terminaison.

take, takeWhile, drop, filter et map restent paresseux et se fusionnent élément par élément ; find, exists et headOption s’arrêtent tôt ; les opérations terminales comme toList et sum forcent le résultat.

Protégez-vous contre les filtres impossibles à satisfaire sur les flux infinis. Vous pouvez désormais générer et consommer des séquences paresseuses en toute confiance.