Method: Fnf::RequestWorker#notify_readable

Defined in:
lib/fnf/worker.rb

#notify_readable ⇒ Object 



8
9
10
11
12
13
14
15
16
17
 
# File 'lib/fnf/worker.rb', line 8

def notify_readable
  data = @pipe.readline.chomp
  fetch = proc {
    payload = MessagePack.unpack(data)
    Connection.send(payload[0], payload[1], payload[2])
  }
  noop = proc { }
  EM.defer fetch, noop

end