Σε ποια δομή δεδομένων στην JavaScript είναι παρόμοιο…

Η δομή δεδομένων κρύου Observable (από τα αγγλικά Cold Observable), η οποία αποτελεί μια έννοια από τον αντιδραστικό προγραμματισμό (π.χ., στη βιβλιοθήκη RxJS).

Βασικά κοινά σημεία:

Αργή φύση: Το Observable αρχίζει να εκπέμπει τιμές μόνο όταν υπάρχει συνδρομητής (subscriber). Χωρίς συνδρομητή, το Observable δεν είναι ενεργό.
Πολλοί συνδρομητές, ανεξάρτητα ρεύματα: Κάθε νέος συνδρομητής λαμβάνει ολόκληρο το σύνολο των τιμών, ξεκινώντας από την αρχή, ανεξάρτητα από άλλους συνδρομητές. Αυτό δημιουργεί ανεξάρτητα ρεύματα δεδομένων για κάθε συνδρομητή.

Παράδειγμα δομής κρύου observable (θεωρητικά):

// Φανταστείτε ότι αυτό είναι ένας "γεννήτορας" τιμών
function generateValues() {
  let i = 0;
  return {
    // Μέθοδος που επιστρέφει την επόμενη τιμή (όταν ζητηθεί)
    next: function() {
      return { value: i++, done: false };
    }
  };
}

// "Observable" - ουσιαστικά, απλώς μια λειτουργία που δέχεται έναν συνδρομητή
function coldObservableExample(subscriber) {
  const generator = generateValues();

  // Προσομοίωση εκπομπής τιμών
  setTimeout(() => {
    subscriber.next(generator.next().value);
  }, 100);

  setTimeout(() => {
    subscriber.next(generator.next().value);
  }, 200);

  setTimeout(() => {
    subscriber.complete(); // Ολοκλήρωση ρεύματος
  }, 300);

  // Επιστρέφουμε το αντικείμενο συνδρομής (για ακύρωση)
  return {
    unsubscribe: () => {
      console.log('Ακύρωση');
      // Εδώ θα μπορούσε να υπάρχει λογική για διακοπή του γεννήτορα/χρονομετρητών
    }
  };
}

// Συνδρομητής 1
const subscription1 = coldObservableExample({
  next: (value) => console.log('Ο συνδρομητής 1 έλαβε:', value),
  error: (err) => console.error('Σφάλμα 1:', err),
  complete: () => console.log('Ο συνδρομητής 1 ολοκληρώθηκε')
});

// Συνδρομητής 2 (θα αρχίσει να λαμβάνει τιμές από την αρχή)
setTimeout(() => {
  const subscription2 = coldObservableExample({
    next: (value) => console.log('Ο συνδρομητής 2 έλαβε:', value),
    error: (err) => console.error('Σφάλμα 2:', err),
    complete: () => console.log('Ο συνδρομητής 2 ολοκληρώθηκε')
  });
}, 150);

// Ακύρωση του πρώτου συνδρομητή
setTimeout(() => {
  subscription1.unsubscribe();
}, 250);

Σε αντίθεση με το hot Observable (θερμό Observable), το οποίο αρχίζει να εκπέμπει τιμές αμέσως, ανεξάρτητα από τους συνδρομητές, και όλοι οι συνδρομητές λαμβάνουν τιμές από τη στιγμή της συνδρομής, το κρύο Observable διατηρεί και αναπαράγει ολόκληρο το ρεύμα δεδομένων για κάθε νέο συνδρομητή. Αυτή η ιδιότητα το φέρνει πιο κοντά στην έννοια του Observable στη JavaScript (στο πλαίσιο του RxJS και παρόμοιων βιβλιοθηκών).

Σύγκριση (απλοποιημένη):

Χαρακτηριστικό	Κρύο Observable	Θερμό Observable
Αρχή εκπομπής	Κατά τη συνδρομή	Αμέσως
Ρεύμα για τους συνδρομητές	Ολόκληρο ρεύμα δεδομένων για κάθε	Τιμές από τη στιγμή της συνδρομής
Χρήση	HTTP αιτήματα, ανάγνωση αρχείων, επανάληψη	Συμβάντα DOM, web-sockets, χρονομετρητές

Σε ποια δομή δεδομένων στην JavaScript είναι παρόμοιο το αντικείμενο Observable;