Class: Swift::Adapter::EMHandler

Inherits:

EM::Connection

• Object
• EM::Connection
• Swift::Adapter::EMHandler

Defined in:

lib/swift/eventmachine.rb

Instance Method Summary

• #initialize(adapter, record, defer) ⇒ EMHandler constructor

  A new instance of EMHandler.

• #notify_readable ⇒ Object

Constructor Details

#initialize(adapter, record, defer) ⇒ EMHandler

Returns a new instance of EMHandler.

# File 'lib/swift/eventmachine.rb', line 12

def initialize adapter, record, defer
  @adapter = adapter
  @record  = record
  @defer   = defer
end

Instance Method Details

#notify_readable ⇒ Object

# File 'lib/swift/eventmachine.rb', line 18

def notify_readable
  detach
  @adapter.pending.shift
  begin
    @defer.succeed(@record ? Result.new(@record, @adapter.result) : @adapter.result)
  rescue Exception => e
    @defer.fail(e)
  end
end