Class: Grid::ZMQ::Stdin

Inherits:
Socket
  • Object
show all
Defined in:
lib/grid/zmq/stdin.rb

Instance Method Summary collapse

Methods inherited from Socket

#send

Constructor Details

#initialize ⇒ Stdin

Returns a new instance of Stdin.



8
9
10
11
12
 
# File 'lib/grid/zmq/stdin.rb', line 8

def initialize
  super(::ZMQ::SUB)

  send(:setsockopt, ::ZMQ::SUBSCRIBE, '')
end

Instance Method Details

#listen(address) ⇒ Object 



14
15
16
17
18
19
20
21
 
# File 'lib/grid/zmq/stdin.rb', line 14

def listen(address)
  send(:connect, address)

  loop do
    send(:recv_string, body = '')
    yield Command.parse(body)
  end
end