class Redis

def pipelined
  synchronize do |client|
    client.pipelined do |raw_pipeline|
      yield PipelinedConnection.new(raw_pipeline)
    end
  end
end