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