class Cql::Client::ConnectStep
@private
Public Class Methods
new(io_reactor, protocol_handler_factory, port, connection_timeout, logger)
click to toggle source
# File lib/cql/client/connector.rb, line 75 def initialize(io_reactor, protocol_handler_factory, port, connection_timeout, logger) @io_reactor = io_reactor @protocol_handler_factory = protocol_handler_factory @port = port @connection_timeout = connection_timeout @logger = logger end
Public Instance Methods
run(pending_connection)
click to toggle source
# File lib/cql/client/connector.rb, line 83 def run(pending_connection) @logger.debug('Connecting to node at %s:%d' % [pending_connection.host, @port]) @io_reactor.connect(pending_connection.host, @port, @connection_timeout, &@protocol_handler_factory).map do |connection| pending_connection.with_connection(connection) end end