Τι είναι το observable;

Observable είναι μια οντότητα που αντιπροσωπεύει μια ροή δεδομένων ή γεγονότων, η οποία μπορεί να είναι ασύγχρονη. Οι παρατηρήσιμες πηγές μπορούν να εκπέμπουν τιμές κατά τη διάρκεια μιας συγκεκριμένης περιόδου, και οι συνδρομητές (Subscribers ή Observers) μπορούν να αντιδράσουν σε αυτές τις τιμές καθώς εμφανίζονται.

Βασικές έννοιες:

• Observable (Παρατηρήσιμη πηγή): Πηγή δεδομένων ή γεγονότων.
• Observer (Παρατηρητής): Αντικείμενο με μεθόδους για να αντιδράσει σε γεγονότα του Observable (next, error, complete).
  • next: Λήψη της επόμενης τιμής.
  • error: Προκύπτει σφάλμα.
  • complete: Το ρεύμα δεδομένων ολοκληρώνεται.
• Subscription (Εγγραφή): Σύνδεση μεταξύ Observable και Observer. Δημιουργείται καλώντας τη μέθοδο subscribe σε ένα Observable. Επιτρέπει στον Observer να λαμβάνει τιμές και να διαχειρίζεται τον κύκλο ζωής της εγγραφής (π.χ., ακύρωση για την αποφυγή διαρροών μνήμης).
• Operators (Τελεστές): Συναρτήσεις για μετασχηματισμό, συνδυασμό και διαχείριση ρευμάτων Observable. Παραδείγματα: map, filter, mergeMap, debounceTime.

Σε αντίθεση με τις Promises, τα Observable μπορούν να εκπέμπουν πολλαπλές τιμές με την πάροδο του χρόνου, αντιπροσωπεύοντας ρεύματα δεδομένων, και όχι ένα μεμονωμένο ασύγχρονο γεγονός.

Παράδειγμα χρήσης σε RxJS (μια δημοφιλής βιβλιοθήκη για αντιδραστικό προγραμματισμό):

import { Observable } from 'rxjs';
import { map } from 'rxjs/operators';

// Δημιουργία Observable από έναν πίνακα
const source = new Observable(observer => {
  observer.next(1);
  observer.next(2);
  observer.next(3);
  observer.complete(); // Ολοκλήρωση ρεύματος
});

// Εγγραφή και χρήση του τελεστή
const subscription = source.pipe(
  map(value => value * 2) // Ο τελεστής map διπλασιάζει κάθε τιμή
).subscribe({
  next: value => console.log(value), // Λαμβάνει τις τιμές: 2, 4, 6
  error: err => console.error(err), // Διαχείριση σφαλμάτων
  complete: () => console.log('Complete!') // Ολοκλήρωση
});

Κύρια πλεονεκτήματα:

• Αντιδραστικός προγραμματισμός: άνετος χειρισμός ασύγχρονων ρευμάτων δεδομένων.
• Συνθέσιμότητα: δυνατότητα εύκολης συνδυασμού και μετασχηματισμού ρευμάτων με τελεστές.
• Διαχείριση κύκλου ζωής: η εγγραφή επιτρέπει τον άμεσο έλεγχο της λήψης δεδομένων και την αποφυγή διαρροών μνήμης.