Что такое паттерн Observer и как он лежит в основе реактивного программирования?

Паттерн Observer (Наблюдатель) — поведенческий шаблон проектирования, позволяющий объектам следить за изменениями в других объектах и автоматически реагировать на них.

Также известен как Publish/Subscribe или Event Listener. Паттерн обеспечивает слабую связность (loose coupling) между компонентами, что делает его основой реактивного программирования, где система должна реагировать на изменения внешних источников данных.

Ключевые компоненты

• Subject — источник данных или событий, управляет подписками наблюдателей
• Observer — получает уведомления при изменении состояния Subject

В реактивной конфигурации Subject публикует изменения, а Observers подписываются на них, что подчёркивает модель потока данных (datastream model).

import java.util.ArrayList;
import java.util.List;

interface Observer {
    void update();
}

class Subject {
    private List<Observer> observers = new ArrayList<>();
    private int state;

    public int getState() {
        return state;
    }

    public void setState(int state) {
        this.state = state;
        notifyAllObservers();
    }

    public void attach(Observer observer) {
        observers.add(observer);
    }

    public void notifyAllObservers() {
        for (Observer observer : observers) {
            observer.update();
        }
    }
}

class ConcreteObserver implements Observer {
    private String name;
    private Subject subject;

    public ConcreteObserver(String name, Subject subject) {
        this.name = name;
        this.subject = subject;
    }

    @Override
    public void update() {
        System.out.println("Observer " + name + " updated. New state: " + subject.getState());
    }
}

public class Main {
    public static void main(String[] args) {
        Subject subject = new Subject();
        ConcreteObserver observer1 = new ConcreteObserver("One", subject);
        ConcreteObserver observer2 = new ConcreteObserver("Two", subject);

        subject.attach(observer1);
        subject.attach(observer2);

        subject.setState(5);
    }
}

В данном примере Subject ведет список подписавшихся Observers и уведомляет их при изменении его состояния.

Практическое применение

• Обработка событий пользовательского интерфейса
• Системы уведомлений
• Отслеживание изменений состояния приложения

Важно помнить, что чрезмерное использование паттерна может привести к усложнению кода и затруднить отладку.

На собеседовании: интервьюер ожидает связку: Observer — это фундамент реактивного программирования, расширенный поддержкой backpressure, операторов и управления потоками. Частая ошибка — не упомянуть, чем реактивный Observer отличается от классического GoF-паттерна (добавлены backpressure и терминальные сигналы onComplete/onError).