module Observable

觀察者模式（也稱為發佈/訂閱）提供了一個簡單的機制，讓一個物件在狀態改變時通知一組有興趣的第三方物件。

機制¶ ↑

發出通知的類別會混入 Observable 模組，此模組提供管理關聯觀察者物件的方法。

可觀察物件必須

• 宣告它具有 #changed

• 呼叫 #notify_observers

觀察者使用 Observable#add_observer 訂閱更新，此方法也會指定透過 notify_observers 呼叫的方法。notify_observers 的預設方法是 update。

範例¶ ↑

以下範例清楚地示範了這一點。當 Ticker 執行時，會持續接收其 @symbol 的股票 Price。Warner 是價格的常駐觀察者，並示範了兩個 warner，分別是 WarnLow 和 WarnHigh，如果價格低於或高於其設定的限制，它們會印出警告。

update 回呼函數允許 warner 在未被明確呼叫的情況下執行。系統會設定 Ticker 和多個觀察者，而觀察者會執行其職責，而頂層程式碼無需干預。

請注意，發布者和訂閱者（可觀察物件和觀察者）之間的合約並未宣告或強制執行。Ticker 發布時間和價格，而 warner 會接收這些資料。但如果您不確保合約正確，沒有其他東西可以警告您。

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

與程序搭配使用¶ ↑

#notify_observers 方法也可以與 +proc+ 一起使用，方法是將 :call 用作 func 參數。

以下範例說明了 lambda 的使用方式

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