модуль Observable

Шаблон наблюдателя (также известный как публикация/подписка) предоставляет простой механизм, позволяющий одному объекту уведомлять набор заинтересованных сторонних объектов об изменениях своего состояния.

Механизм

Уведомляющий класс смешивает модуль Observable, который предоставляет методы для управления связанными наблюдателями.

Объект наблюдаемого должен:

• убедиться, что у него есть #changed

• вызвать #notify_observers

Наблюдатель подписывается на обновления с помощью #add_observer, который также указывает вызываемый метод через notify_observers. По умолчанию для notify_observers используется метод update.

Пример

Следующий пример наглядно демонстрирует это. Ticker, при запуске, непрерывно получает Price акций для своего @symbol. Warner - это общий наблюдатель цены, и показаны два предупредителя: WarnLow и WarnHigh, которые выдают предупреждение, если цена ниже или выше установленных ими пределов соответственно.

Обратный вызов update позволяет предупредителям работать без явного вызова. Система настроена с Ticker и несколькими наблюдателями, и наблюдатели выполняют свою работу без вмешательства кода верхнего уровня.

Обратите внимание, что договор между издателем и подписчиком (наблюдаемым и наблюдателем) не объявлен и не применяется. Ticker публикует время и цену, а предупредители их получают. Но если вы не гарантируете правильность своих договоров, ничего другого не сможет вас предупредить.

require "observer"

class Ticker          ### Periodically fetch a stock price.
  include Observable

  def initialize(symbol)
    @symbol = symbol
  end

  def run
    last_price = nil
    loop do
      price = Price.fetch(@symbol)
      print "Current price: #{price}\n"
      if price != last_price
        changed                 # notify observers
        last_price = price
        notify_observers(Time.now, price)
      end
      sleep 1
    end
  end
end

class Price           ### A mock class to fetch a stock price (60 - 140).
  def self.fetch(symbol)
    60 + rand(80)
  end
end

class Warner          ### An abstract observer of Ticker objects.
  def initialize(ticker, limit)
    @limit = limit
    ticker.add_observer(self)
  end
end

class WarnLow < Warner
  def update(time, price)       # callback for observer
    if price < @limit
      print "--- #{time.to_s}: Price below #@limit: #{price}\n"
    end
  end
end

class WarnHigh < Warner
  def update(time, price)       # callback for observer
    if price > @limit
      print "+++ #{time.to_s}: Price above #@limit: #{price}\n"
    end
  end
end

ticker = Ticker.new("MSFT")
WarnLow.new(ticker, 80)
WarnHigh.new(ticker, 120)
ticker.run

Результат:

Current price: 83
Current price: 75
--- Sun Jun 09 00:10:25 CDT 2002: Price below 80: 75
Current price: 90
Current price: 134
+++ Sun Jun 09 00:10:25 CDT 2002: Price above 120: 134
Current price: 134
Current price: 112
Current price: 79
--- Sun Jun 09 00:10:25 CDT 2002: Price below 80: 79