Wie Streams API Peek() -Funktion verwenden und es funktioniert?

Question

Nach this question, peek() ist faul, heißt es, wir sollten es irgendwie aktivieren. In der Tat, um es zu aktivieren, etwas zu der Konsole mich schon versucht, diese drucken:

Stream<String> ss = Stream.of("Hi","Hello","Halo","Hacker News"); 
ss.parallel().peek(System.out::println); 
System.out.println("lol"); // I wrote this line to print sth out to terminal to wake peek method up 

Aber das funktioniert nicht und der Ausgang ist:

lol 

So wie kann ich die peek funktionieren tatsächlich?

Wenn es keinen Weg zu dem gibt, was ist der Punkt der Verwendung von peek?

Answer 1

Sie müssen in einem Stream für die Ausführung verwenden (Peek ist kein Terminal, es ist eine Zwischenoperation, die einen neuen Stream zurückgibt), z. count():

Stream<String> ss = Stream.of("Hi","Hello","Halo","Hacker News"); 
ss.parallel().peek(System.out::println).count(); 

Oder ersetzen peek mit forEach (das Terminal):

ss.parallel().forEach(System.out::println); 

Answer 2

peek() -Methode Consumer als Parameter verwendet, was bedeutet, dass potenziell Sie den Status des eingehenden mutieren kann Element. Zur gleichen Zeit sagt Java-Dokumentation, dass peek sollte hauptsächlich für Debugging-Zwecke verwendet werden. Es ist ein Zwischen-Operator und erfordert einen Terminal-Operator wie forEach.

stream().peek(Consumer).forEach(Consumer);