Module: Isono::EventObservable

Included in:
EventDelegateContext, Node
Defined in:
lib/isono/event_observable.rb

Overview

Add event handling support to the arbitrary class. TODO: make it thread safe.

Defined Under Namespace

Classes: Timeout

Instance Method Summary collapse

Instance Method Details

#add_observer(evtype, &blk) ⇒ Object 



43
44
45
46
47
48
 
# File 'lib/isono/event_observable.rb', line 43

def add_observer(evtype, &blk)
  ticket = Util.gen_id
  @handlers[ticket] = blk
  (@tickets[evtype] ||= []) << ticket
  ticket
end

#add_observer_once(evtype, timeout = 0, &blk) ⇒ Object 



50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
 
# File 'lib/isono/event_observable.rb', line 50

def add_observer_once(evtype, timeout=0, &blk)
  ticket = add_observer(evtype) { |*args|
    begin
      blk.call(*args)
    ensure
      remove_observer(ticket)
    end
  }

  if timeout > 0
    EM.add_timer(timeout) {
      if @handlers.has_key? ticket
        blk.call(Timeout.new)
        remove_observer(ticket)
      end
    }
  end
  
  ticket
end

#fire_event(evtype, *args) ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
 
# File 'lib/isono/event_observable.rb', line 10

def fire_event(evtype, *args)
  if logger && @debug_event
    logger.debug("fire_event(#{evtype}, #{args.nil? ? 'nil' : args.inspect})")
  end
  begin
    on_event_fired(evtype, *args)
  rescue => e
    if logger
      logger.error(e)
    else
      puts e
    end
  end
  return unless @tickets[evtype]

  deleted_tickets = []
  @tickets[evtype].each { |ticket|
    h = @handlers[ticket]
    if h
      begin
        h.call(*args)
      rescue Exception => e
        logger.error("caught exception: #{ticket}, proc=#{h.to_s}: #{e.to_s}")
        logger.error(e)
      end
    else
      deleted_tickets << ticket
    end
  }

  @tickets[evtype] -= deleted_tickets
end

#remove_observer(ticket) ⇒ Object 



71
72
73
 
# File 'lib/isono/event_observable.rb', line 71

def remove_observer(ticket)
  @handlers.delete(ticket)
end