lib/async/http/client.rb in async-http-0.48.0 vs lib/async/http/client.rb in async-http-0.48.1

@@ -73,9 +73,14 @@
 					client.close
 				end
 			end
 			
 			def close
+				while @pool.busy?
+					Async.logger.warn(self) {"Waiting for pool to drain: #{@pool}"}
+					@pool.wait
+				end
+				
 				@pool.close
 			end
 			
 			def call(request)
 				request.scheme ||= self.scheme