модуль Observable

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

Механизм

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

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

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

• вызвать #notify_observers

Наблюдатель подписывается на обновления с помощью Observable#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

Использование с procs

Метод #notify_observers также может быть использован с +proc+s, используя :call в качестве параметра func.

Следующий пример демонстрирует использование лямбда-выражения:

require 'observer'

class Ticker
  include Observable

  def run
    # logic to retrieve the price (here 77.0)
    changed
    notify_observers(77.0)
  end
end

ticker = Ticker.new
warner = ->(price) { puts "New price received: #{price}" }
ticker.add_observer(warner, :call)
ticker.run