class OtStatus::Query::Connection

Constants

QUERY

Attributes

query[R]

Public Class Methods

new(query, connect_timeout, inactivity_timeout) click to toggle source
# File lib/otstatus.rb, line 36
def initialize query, connect_timeout, inactivity_timeout
  @query = query
  self.pending_connect_timeout = connect_timeout
  self.comm_inactivity_timeout = inactivity_timeout
end

Public Instance Methods

post_init() click to toggle source
# File lib/otstatus.rb, line 42
def post_init
  send_data QUERY
  @data = ""
end
receive_data(data) click to toggle source
# File lib/otstatus.rb, line 47
def receive_data data
  @data << data
  query.response = @data
end
unbind() click to toggle source
# File lib/otstatus.rb, line 52
def unbind
  EventMachine::stop_event_loop
end