Class: IProto::EMFiberedConnection

Inherits:

EMConnection

• Object
• EM::Connection
• EMConnection
• IProto::EMFiberedConnection

Defined in:

lib/iproto/em.rb

Constant Summary

Constants included from ConnectionAPI

ConnectionAPI::BINARY, ConnectionAPI::DEFAULT_RECONNECT, ConnectionAPI::EMPTY_STR, ConnectionAPI::HEADER_SIZE, ConnectionAPI::PING, ConnectionAPI::PING_ID

Instance Attribute Summary

Attributes inherited from EMConnection

#_needed_size, #host, #port

Instance Method Summary

• #send_request(request_type, body) ⇒ Object

Methods inherited from EMConnection

#_do_send_request, #_perform_waiting_for_connect, #_ping, #_send_request, #_setup_reconnect_timer, #_stop_pinger, #close, #close_connection, #comm_inactivity_timeout=, #connected?, #connection_completed, #could_be_connected?, #discard_requests, #do_response, #init_protocol, #initialize, #receive_chunk, #shutdown_hook, #unbind, #waiting_requests_size

Methods included from IProto::EMConnection::FixedLengthProtocol

#buffer_reset, #post_init, #receive_chunk, #receive_data

Methods included from ConnectionAPI

#next_request_id, #pack_request

Constructor Details

This class inherits a constructor from IProto::EMConnection

Instance Method Details

#send_request(request_type, body) ⇒ Object

# File 'lib/iproto/em.rb', line 255

def send_request(request_type, body)
  _send_request(request_type, body, Fiber.current)
  result = Fiber.yield
  raise result  if Exception === result
  result
end