Module: Concurrent::Observable

Included in:
Agent, IVar, TimerTask
Defined in:
lib/concurrent/observable.rb

Instance Method Summary collapse

Instance Method Details

#add_observer(*args, &block) ⇒ Object

Returns the added observer.

Returns:

  • (Object) —

    the added observer



9
10
11
 
# File 'lib/concurrent/observable.rb', line 9

def add_observer(*args, &block)
  observers.add_observer(*args, &block)
end

#count_observers ⇒ Integer

Returns the observers count.

Returns:

  • (Integer) —

    the observers count



32
33
34
 
# File 'lib/concurrent/observable.rb', line 32

def count_observers
  observers.count_observers
end

#delete_observer(*args) ⇒ Object

Returns the deleted observer.

Returns:

  • (Object) —

    the deleted observer



21
22
23
 
# File 'lib/concurrent/observable.rb', line 21

def delete_observer(*args)
  observers.delete_observer(*args)
end

#delete_observers ⇒ Observable

Returns self.

Returns:



26
27
28
29
 
# File 'lib/concurrent/observable.rb', line 26

def delete_observers
  observers.delete_observers
  self
end

#with_observer(*args, &block) ⇒ Observable

as #add_observer but it can be used for chaning

Returns:



15
16
17
18
 
# File 'lib/concurrent/observable.rb', line 15

def with_observer(*args, &block)
  add_observer *args, &block
  self
end