lib/em-jack/connection.rb in em-jack-0.0.7 vs lib/em-jack/connection.rb in em-jack-0.0.8

- old
+ new

@@ -143,9 +143,10 @@ @retries = 0 end def disconnected @deferrables.each { |df| df.fail(:disconnected) } + @deferrables = [] raise EMJack::Disconnected if @retries >= RETRY_COUNT @retries += 1 EM.add_timer(1) { @conn.reconnect(@host, @port) } end