Skip to content

Commit

Permalink
Attempt to avoid inadvertently shutting down Celluloid
Browse files Browse the repository at this point in the history
  • Loading branch information
benlangfeld committed Jun 25, 2015
1 parent 5a0a969 commit a7b0185
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions lib/adhearsion/rayo/initializer.rb
Original file line number Diff line number Diff line change
Expand Up @@ -54,20 +54,20 @@ def init
handle_event event
end

Events.rayo Adhearsion::Rayo::Connection::Connected do |event|
Events.register_callback :rayo, Adhearsion::Rayo::Connection::Connected do |event|
logger.info "Connected to Rayo server"
self.attempts = 0
end

Events.rayo Adhearsion::Event::Offer do |offer|
Events.register_callback :rayo, Adhearsion::Event::Offer do |offer|
dispatch_offer offer
end

Events.rayo proc { |e| e.respond_to?(:source) }, :source do |event|
Events.register_callback :rayo, proc { |e| e.respond_to?(:source) }, :source do |event|
event.source.trigger_event_handler event
end

Events.rayo proc { |e| e.respond_to?(:target_call_id) }, :target_call_id do |event|
Events.register_callback :rayo, proc { |e| e.respond_to?(:target_call_id) }, :target_call_id do |event|
dispatch_call_event event
end
end
Expand All @@ -81,12 +81,12 @@ def connect
m = Mutex.new
blocker = ConditionVariable.new

Events.rayo Adhearsion::Rayo::Connection::Connected do
Events.register_callback :rayo, Adhearsion::Rayo::Connection::Connected do
Adhearsion::Process.booted
m.synchronize { blocker.broadcast }
end

Events.shutdown do
Events.register_callback :shutdown do
logger.info "Shutting down while connecting. Breaking the connection block."
m.synchronize { blocker.broadcast }
end
Expand Down

0 comments on commit a7b0185

Please sign in to comment.