В мире программирования существуют различные шаблоны и парадигмы, которые помогают нам создавать надежные и масштабируемые приложения. Два таких шаблона, шаблон наблюдателя и шаблон итератора, играют решающую роль в обработке событий и обходе коллекций соответственно. В последние годы эти шаблоны были объединены для создания парадигмы Reactive Stream, которая предлагает мощные возможности для обработки асинхронных потоков данных. В этой статье мы рассмотрим методы и предоставим примеры кода, демонстрирующие интеграцию шаблона наблюдателя и шаблона итератора для создания реактивных потоков.

1. Шаблон наблюдателя:
   Шаблон наблюдателя обеспечивает связь между объектами по принципу «один-ко-многим». Он состоит из следующих компонентов:

• Субъект: объект, который поддерживает список наблюдателей и уведомляет их о любых изменениях состояния.
• Наблюдатель: интерфейс или класс, определяющий метод обновления, который вызывается субъектом при возникновении изменения.

Пример кода:

interface Observer {
    void update(String message);
}
class Subject {
    private List<Observer> observers = new ArrayList<>();
    public void attach(Observer observer) {
        observers.add(observer);
    }
    public void detach(Observer observer) {
        observers.remove(observer);
    }
    public void notifyObservers(String message) {
        for (Observer observer : observers) {
            observer.update(message);
        }
    }
// Other subject-related methods...
}

2. Шаблон «Итератор».
   Шаблон «Итератор» позволяет перемещаться по коллекциям, не раскрывая их базовую структуру. Он состоит из следующих компонентов:

• Итератор: интерфейс или класс, определяющий методы для обхода коллекции.
• Коллекция: интерфейс или класс, представляющий коллекцию объектов.

Пример кода:

interface Iterator<T> {
    boolean hasNext();
    T next();
}
class Collection<T> {
    private List<T> elements = new ArrayList<>();
    public void add(T element) {
        elements.add(element);
    }
    public Iterator<T> createIterator() {
        return new CollectionIterator();
    }
    private class CollectionIterator implements Iterator<T> {
        private int currentIndex = 0;
        @Override
        public boolean hasNext() {
            return currentIndex < elements.size();
        }
        @Override
        public T next() {
            if (hasNext()) {
                return elements.get(currentIndex++);
            }
            throw new NoSuchElementException();
        }
    }
// Other collection-related methods...
}

3. Реактивный поток.
   Реактивный поток — это расширение шаблонов Observer и Iterator, разработанное специально для обработки асинхронных потоков данных. В нем представлены дополнительные методы и концепции, обеспечивающие эффективную и неблокирующую обработку потока.

Пример кода:

import java.util.concurrent.Flow.*;
class ReactiveStreamExample {
    public static void main(String[] args) {
        Publisher<Integer> publisher = new Publisher<>() {
            public void subscribe(Subscriber<? super Integer> subscriber) {
                Iterator<Integer> iterator = new Collection<Integer>().createIterator();
                while (iterator.hasNext()) {
                    subscriber.onNext(iterator.next());
                }
                subscriber.onComplete();
            }
        };
        Subscriber<Integer> subscriber = new Subscriber<>() {
            public void onSubscribe(Subscription subscription) {
                // Perform initialization tasks
            }
            public void onNext(Integer item) {
                // Process the received item
            }
            public void onError(Throwable throwable) {
                // Handle error conditions
            }
            public void onComplete() {
                // Perform cleanup tasks
            }
        };
        publisher.subscribe(subscriber);
    }
// Other reactive stream-related methods...
}

Интеграция шаблонов наблюдателя и шаблона итератора в парадигму реактивного потока предлагает мощный и гибкий подход к обработке асинхронных потоков данных. Объединив сильные стороны этих шаблонов, разработчики могут создавать эффективные и масштабируемые приложения. Понимание методов и примеров, представленных в этой статье, послужит прочной основой для разработки и реализации Reactive Streams в ваших проектах.