Module: Salus::Observable

Included in:
Future, ThreadPool::Task
Defined in:
lib/salus/thread/observable.rb

Instance Method Summary collapse

Instance Method Details

#add_observer(observer = nil, func = :update, &block) ⇒ Object 



75
76
77
 
# File 'lib/salus/thread/observable.rb', line 75

def add_observer(observer=nil, func=:update, &block)
  observers.add(observer, func, &block)
end

#count_observers ⇒ Object 



84
85
86
 
# File 'lib/salus/thread/observable.rb', line 84

def count_observers
  observers.count
end

#delete_observer(observer) ⇒ Object 



88
89
90
 
# File 'lib/salus/thread/observable.rb', line 88

def delete_observer(observer)
  observers.delete(observer)
end

#delete_observers ⇒ Object 



92
93
94
95
 
# File 'lib/salus/thread/observable.rb', line 92

def delete_observers
  observers.delete_all
  self
end

#notify_and_delete_observers(*args, &block) ⇒ Object 



102
103
104
105
 
# File 'lib/salus/thread/observable.rb', line 102

def notify_and_delete_observers(*args, &block)
  observers.notify_and_delete(*args, &block)
  self
end

#notify_observers(*args, &block) ⇒ Object 



97
98
99
100
 
# File 'lib/salus/thread/observable.rb', line 97

def notify_observers(*args, &block)
  observers.notify(*args, &block)
  self
end

#with_observer(observer = nil, func = :update, &block) ⇒ Object 



79
80
81
82
 
# File 'lib/salus/thread/observable.rb', line 79

def with_observer(observer=nil, func=:update, &block)
  observers.add(observer, func, &block)
  self
end