Πώς να εργαστείτε με ροές (streams) σε Kotlin;

Στην Kotlin, για εργασία με ροές δεδομένων (παρόμοιο με το Java 8 Streams API), χρησιμοποιούνται επεκτατικές συναρτήσεις για συλλογές, που παρέχονται από τη βιβλιοθήκη των τυπικών συναρτήσεων. Δεν είναι ένα ξεχωριστό API, αλλά ένα σύνολο μεθόδων από το kotlin.collections.

Οι βασικές λειτουργίες με ροές διακρίνονται σε:

• Μεταβατικές (Intermediate operations): Επιστρέφουν μια νέα συλλογή και είναι "τεμπέλικες" (εκτελούνται μόνο κατά την κλήση μιας τελικής λειτουργίας). Παραδείγματα: filter, map, flatMap, distinct, sorted, take, drop.
• Τερματικές (Terminal operations): Ολοκληρώνουν τη σειρά λειτουργιών και επιστρέφουν το αποτέλεσμα (όχι μια συλλογή). Ενεργοποιούν την εκτέλεση όλων των μεταβατικών λειτουργιών. Παραδείγματα: forEach, reduce, fold, count, sum, average, min, max, toList, toSet, toMap.

Υπάρχει επίσης η έννοια των σειρών (sequences), που παρέχουν ρητή τεμπελιά. Οι sequences επεξεργάζονται τα στοιχεία ένα-ένα, καθώς χρειάζεται, κάτι που μπορεί να είναι πιο αποδοτικό για μεγάλες συλλογές ή μακριά chains λειτουργιών:

• Δημιουργία σειράς: collection.asSequence()
• Επιστροφή σε συλλογή: sequence.toList()

// Παράδειγμα χρήσης των τυπικών λειτουργιών για επεξεργασία ροών
fun processCollection() {
    val numbers = listOf(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)

    val evenSquares = numbers
        .filter { it % 2 == 0 } // Μεταβατική λειτουργία: φιλτράρουμε τους ζυγούς αριθμούς
        .map { it * it }     // Μεταβατική λειτουργία: υψώνουμε στο τετράγωνο

    println(evenSquares) // Τερματική λειτουργία: εμφανίζει τη συλλογή (εκτελεί το φίλτρο και το map)

    val sumOfOdd = numbers
        .filter { it % 2 != 0 } // Μεταβατική
        .sum()                // Τερματική (εκτελείται): υπολογίζει το άθροισμα των περιττών

    println(sumOfOdd)
}

// Παράδειγμα χρήσης sequences
fun processSequence() {
    val largeCollection = (1..1_000_000).toList()

    // Με συλλογές (μη τεμπέλικες): filter και map θα εκτελεστούν για όλα τα στοιχεία
    val resultCollection = largeCollection
        .filter { it % 2 == 0 }
        .map { it * 2 }
        .take(10) // take(10) εκτελείται μετά το φίλτρο και το map για όλα

    println("Result Collection size: ${resultCollection.size}")

    // Με sequences (τεμπέλικες): filter, map και take εκτελούνται στοιχείο-με-στοιχείο
    val resultSequence = largeCollection.asSequence()
        .filter { it % 2 == 0 } // filter εκτελείται για κάθε στοιχείο
        .map { it * 2 }     // map εκτελείται για κάθε περασμένο από το φίλτρο στοιχείο
        .take(10)         // take(10) σταματά την επεξεργασία μετά από 10 στοιχεία

    println("Result Sequence size: ${resultSequence.toList().size}") // toList() ενεργοποιεί την εκτέλεση της sequence
}

fun main() {
    processCollection()
    processSequence()
}

Πίνακας σύγκρισης των τυπικών λειτουργιών και sequences σχετικά με την τεμπελιά:

Χαρακτηριστικό	Τυπικές λειτουργίες συλλογών	Sequences
Τεμπελιά	Έμμεση τεμπελιά για τις μεταβατικές λειτουργίες, αλλά η τελική λειτουργία επεξεργάζεται ολόκληρη τη αλυσίδα	Ρητή τεμπελιά: οι λειτουργίες εκτελούνται στοιχείο-με-στοιχείο καθώς χρειάζεται
Αποτελεσματικότητα	Μπορεί να είναι λιγότερο αποδοτική για μεγάλες συλλογές και μακριές αλυσίδες λειτουργιών λόγω των ενδιάμεσων συλλογών	Πιο αποδοτική για μεγάλες συλλογές και μακριές αλυσίδες λειτουργιών
Εφαρμογή	Κατάλληλη για μικρές και μεσαίες συλλογές	Κατάλληλη για μεγάλες συλλογές ή λειτουργίες που μπορούν να διακοπούν νωρίς (take, find, first, any, all, none)

Η χρήση των τυπικών λειτουργιών σε συλλογές είναι συχνά επαρκής και πιο συνοπτική. Οι sequences προτείνονται όταν χρειάζεται ρητή τεμπελιά για βελτιστοποίηση της απόδοσης με μεγάλα δεδομένα.