Class: GearmanAdminClient::Connection

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/gearman_admin_client/connection.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(io) ⇒ Connection

Returns a new instance of Connection.



11
12
13
 
# File 'lib/gearman_admin_client/connection.rb', line 11

def initialize(io)
  @io = io
end

Instance Attribute Details

#io ⇒ Object (readonly)

Returns the value of attribute io.



9
10
11
 
# File 'lib/gearman_admin_client/connection.rb', line 9

def io
  @io
end

Instance Method Details

#drain ⇒ Object 



25
26
27
28
29
30
31
32
33
34
 
# File 'lib/gearman_admin_client/connection.rb', line 25

def drain
  output = ''

  while line = read
    break if line.chop == '.'
    output << line
  end

  output
end

#read ⇒ Object 



20
21
22
23
 
# File 'lib/gearman_admin_client/connection.rb', line 20

def read
  IO::select([io])
  io.gets
end

#write(command) ⇒ Object 



15
16
17
18
 
# File 'lib/gearman_admin_client/connection.rb', line 15

def write(command)
  IO::select([], [io])
  io.puts(command)
end