lib/pigato/client.rb in pigato-0.1.6 vs lib/pigato/client.rb in pigato-0.1.7
- old
+ new
@@ -38,9 +38,10 @@
d1 = Time.now
while 1 do
@client.recv_strings(msg, ZMQ::DONTWAIT)
msg = [] if msg.length < 5 || msg[3] != rid
break if msg.length > 0 || ((Time.now - d1) * 1000 > timeout)
+ sleep(1.0 / 50.0)
end
return nil if msg.length == 0
# header