lib/redic/pool.rb in redic-pool-1.0.0 vs lib/redic/pool.rb in redic-pool-1.0.1

@@ -1,10 +1,10 @@
 require "connection_pool"
 require "redic"
 
 class Redic::Pool
-  VERSION = "1.0.0"
+  VERSION = "1.0.1"
 
   attr :url
   attr :pool
 
   def initialize(url, options = {})
@@ -29,9 +29,13 @@
     @pool.with do |client|
       Thread.current[@id].each do |args|
         client.queue(*args)
       end
 
-      client.commit
+      result = client.commit
+
+      Thread.current[@id].clear
+
+      result
     end
   end
 end