lib/pigato/worker.rb in pigato-0.2.8 vs lib/pigato/worker.rb in pigato-0.2.9

- old
+ new

@@ -23,10 +23,10 @@ def reply reply reply = [@reply_to, '', @reply_rid, '0'].concat([Oj.dump(reply)]) send_to_broker Pigato::W_REPLY, reply end - def recv reply + def recv loop do @reply_rid = nil @reply_to = nil @reply_service = nil