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