Method: Redis::Pipeline#initialize

Defined in:
lib/redis/pipeline.rb

#initialize(client) ⇒ Pipeline

Returns a new instance of Pipeline.



73
74
75
76
77
78
# File 'lib/redis/pipeline.rb', line 73

def initialize(client)
  @client = client.is_a?(Pipeline) ? client.client : client
  @with_reconnect = true
  @shutdown = false
  @futures = []
end