mirror of
https://github.com/cyberarm/cyberarm_engine.git
synced 2025-12-16 21:22:33 +00:00
48 lines
1.1 KiB
Ruby
48 lines
1.1 KiB
Ruby
module CyberarmEngine
|
|
module Event # Gets included into Element
|
|
def subscribe(event, method = nil, &block)
|
|
handler = method || block
|
|
@event_handler[event] << handler
|
|
|
|
Subscription.new(self, event, handler)
|
|
end
|
|
|
|
def unsubscribe(subscription)
|
|
end
|
|
|
|
def publish(event, *args)
|
|
raise ArgumentError, "#{self.class} does not handle #{event.inspect}" unless @event_handler.include?(event)
|
|
|
|
return unless enabled?
|
|
|
|
return :handled if respond_to?(event) && (send(event, self, *args) == :handled)
|
|
|
|
@event_handler[event].reverse_each do |handler|
|
|
return :handled if handler.call(self, *args) == :handled
|
|
end
|
|
|
|
parent.publish(event, *args) if parent
|
|
nil
|
|
end
|
|
|
|
def event(event)
|
|
@event_handler ||= {}
|
|
@event_handler[event] ||= []
|
|
end
|
|
end
|
|
|
|
class Subscription
|
|
attr_reader :publisher, :event, :handler
|
|
|
|
def initialize(publisher, event, handler)
|
|
@publisher = publisher
|
|
@event = event
|
|
@handler = handler
|
|
end
|
|
|
|
def unsubscribe
|
|
@publisher.unsubscribe(self)
|
|
end
|
|
end
|
|
end
|