Obserwator

// Bazowa klasa publikującego zawiera kod zarządzania
// subskrypcją i metody powiadamiania.
class EventManager is
    // Tablica asocjacyjna typów zdarzeń i słuchaczy.
    private field listeners: hash map

    method subscribe(eventType, listener) is
        listeners.add(eventType, listener)

    method unsubscribe(eventType, listener) is
        listeners.remove(eventType, listener)

    method notify(eventType, data) is
        foreach (listener in listeners.of(eventType)) do
            listener.update(data)

// Konkretny publikujący zawiera prawdziwą logikę biznesową
// która jest istotna z punktu widzenia niektórych
// subskrybentów. Moglibyśmy pozyskać tę klasę z klasy bazowej
// publikującego, ale nie jest to zawsze możliwe w prawdziwym
// świecie, ponieważ konkretny publikujący może już być
// podklasą. W takim przypadku można wkomponować logikę
// subskrypcji w sposób pokazany poniżej.
class Editor is
    public field events: EventManager
    private field file: File

    constructor Editor() is
        events = new EventManager()

    // Metody logiki biznesowej mogą powiadamiać subskrybentów o
    // zmianach.
    method openFile(path) is
        this.file = new File(path)
        events.notify("open", file.name)

    method saveFile() is
        file.write()
        events.notify("save", file.name)

    // ...


// Oto interfejs subskrybenta. Jeśli język programowania którego
// używasz obsługuje typy funkcyjne, możesz wymienić całą
// hierarchię subskrypcji zestawem funkcji.
interface EventListener is
    method update(filename)

// Konkretni subskrybenci reagują na aktualizacje emitowane
// przez obiekt publikujący do którego są przywiązane.
class LoggingListener implements EventListener is
    private field log: File
    private field message: string

    constructor LoggingListener(log_filename, message) is
        this.log = new File(log_filename)
        this.message = message

    method update(filename) is
        log.write(replace('%s',filename,message))

class EmailAlertsListener implements EventListener is
    private field email: string
    private field message: string

    constructor EmailAlertsListener(email, message) is
        this.email = email
        this.message = message

    method update(filename) is
        system.email(email, replace('%s',filename,message))


// Aplikacja może konfigurować publikujących i subskrybentów w
// trakcie działania programu.
class Application is
    method config() is
        editor = new Editor()

        logger = new LoggingListener(
            "/path/to/log.txt",
            "Someone has opened the file: %s")
        editor.events.subscribe("open", logger)

        emailAlerts = new EmailAlertsListener(
            "admin@example.com",
            "Someone has changed the file: %s")
        editor.events.subscribe("save", emailAlerts)