em_spec.rb in mysql2-0.3.13

- old
+ new

@@ -10,17 +10,19 @@
       EM.run do
         client1 = Mysql2::EM::Client.new DatabaseCredentials['root']
         defer1 = client1.query "SELECT sleep(0.1) as first_query"
         defer1.callback do |result|
           results << result.first
+          client1.close
           EM.stop_event_loop
         end
 
         client2 = Mysql2::EM::Client.new DatabaseCredentials['root']
         defer2 = client2.query "SELECT sleep(0.025) second_query"
         defer2.callback do |result|
           results << result.first
+          client2.close
         end
       end
 
       results[0].keys.should include("second_query")
       results[1].keys.should include("first_query")
@@ -32,12 +34,13 @@
         client = Mysql2::EM::Client.new DatabaseCredentials['root']
         defer1 = client.query "SELECT sleep(0.025) as first_query"
         defer1.callback do |result|
           results << result.first
           defer2 = client.query "SELECT sleep(0.025) as second_query"
-          defer2.callback do |result|
-            results << result.first
+          defer2.callback do |r|
+            results << r.first
+            client.close
             EM.stop_event_loop
           end
         end
       end
 
@@ -49,9 +52,10 @@
       lambda {
         EM.run do
           client = Mysql2::EM::Client.new DatabaseCredentials['root']
           defer = client.query "SELECT sleep(0.1) as first_query"
           defer.callback do |result|
+            client.close
             raise 'some error'
           end
           defer.errback do |err|
             # This _shouldn't_ be run, but it needed to prevent the specs from
             # freezing if this test fails.