Module: ObServ::DSL

Defined in:
lib/ob_serv.rb

Instance Method Summary collapse

Instance Method Details

#publish(event, *args) ⇒ Object



9
10
11
12
# File 'lib/ob_serv.rb', line 9

def publish(event, *args)
  # ObServ.publish event, *args
  ObServ.config[:publish].call(event, *args)
end

#subscribe(event, on: :receive) ⇒ Object



4
5
6
7
# File 'lib/ob_serv.rb', line 4

def subscribe(event, on: :receive)
  return ObServ.register self, event, on: on, &Proc.new if block_given?
  ObServ.register self, event, on: on
end