class Redis

def pipelined
  synchronize do |client|
    begin
      pipeline = Pipeline.new(@client)
      original, @client = @client, pipeline
      yield(self)
      original.call_pipeline(@client)
    ensure
      @client = original
    end
  end
end