class Redis::PipelinedConnection

def send_command(command, &block)
  future = Future.new(command, block, @exception)
  @pipeline.call_v(command) do |result|
    future._set(result)
  end
  @futures << future
  future
end