Method: MessageBus::Client#ensure_closed!

Defined in:
lib/message_bus/client.rb

#ensure_closed! ⇒ Object 



20
21
22
23
24
25
26
27
 
# File 'lib/message_bus/client.rb', line 20

def ensure_closed!
  return unless in_async?
  write_and_close "[]"
rescue
  # we may have a dead socket, just nil the @io
  @io = nil
  @async_response = nil
end