lib/redis/base_object.rb in redis-objects-1.0.1 vs lib/redis/base_object.rb in redis-objects-1.1.0

@@ -2,10 +2,10 @@
   # Defines base functionality for all redis-objects.
   class BaseObject
     def initialize(key, *args)
       @key     = key.is_a?(Array) ? key.flatten.join(':') : key
       @options = args.last.is_a?(Hash) ? args.pop : {}
-      @myredis = args.first
+      @myredis = Objects::ConnectionPoolProxy.proxy_if_needed(args.first)
     end
 
     # Dynamically query the handle to enable resetting midstream
     def redis
       @myredis || ::Redis::Objects.redis