class Redis::PipelinedConnection

# File lib/redis/pipeline.rb, line 9
def initialize(pipeline, futures = [], exception: true)
  @pipeline = pipeline
  @futures = futures
  @exception = exception
end

# File lib/redis/pipeline.rb, line 21
def multi
  transaction = MultiConnection.new(@pipeline, @futures)
  send_command([:multi])
  size = @futures.size
  yield transaction
  multi_future = MultiFuture.new(@futures[size..-1])
  @pipeline.call_v([:exec]) do |result|
    multi_future._set(result)
  end
  @futures << multi_future
  multi_future
end

# File lib/redis/pipeline.rb, line 17
def pipelined
  yield self
end