class Rev::Socket::Connector

Public Instance Methods

on_writable() click to toggle source
# File lib/rev/socket.rb, line 57
def on_writable
  evl = evloop
  detach

  if connect_successful?
    @rev_socket.instance_eval { @_connector = nil }
    @rev_socket.attach(evl)
    @ruby_socket.setsockopt(::Socket::IPPROTO_TCP, ::Socket::TCP_NODELAY, [1].pack("l"))
    @ruby_socket.setsockopt(::Socket::SOL_SOCKET, ::Socket::SO_KEEPALIVE, true)

    @rev_socket.__send__(:on_connect)
  else
    @rev_socket.instance_eval { @_failed = true }
    @rev_socket.__send__(:on_connect_failed)
  end
end

Public Class Methods

new(rev_socket, ruby_socket) click to toggle source
# File lib/rev/socket.rb, line 52
def initialize(rev_socket, ruby_socket)
  @rev_socket, @ruby_socket = rev_socket, ruby_socket
  super(ruby_socket, :w)
end