К какой структуре данных в JavaScript близок объект Observable?

К структуре данных холодный 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);

В отличие от горячего Observable (Hot Observable), который начинает эмитить значения сразу, независимо от подписчиков, и все подписчики получают значения с момента подписки, холодный Observable сохраняет и воспроизводит полный поток данных для каждого нового подписчика. Именно эта характеристика сближает его с концепцией Observable в JavaScript (в контексте RxJS и подобных библиотек).

Сравнение (упрощенно):