X-Git-Url: https://git.saurik.com/redis.git/blobdiff_plain/57172ffb316b5e681c4f515927894f5129739237..edd9f775f0b51f031a04c7fc7573b276d152a74f:/client-libraries/ruby/lib/pipeline.rb diff --git a/client-libraries/ruby/lib/pipeline.rb b/client-libraries/ruby/lib/pipeline.rb index deaedd15..f92b96db 100644 --- a/client-libraries/ruby/lib/pipeline.rb +++ b/client-libraries/ruby/lib/pipeline.rb @@ -9,10 +9,7 @@ class Redis @commands = [] end - def get_response - end - - def write(data) + def execute_command(data) @commands << data write_and_read if @commands.size >= BUFFER_SIZE end @@ -22,10 +19,10 @@ class Redis end def write_and_read - @redis.write @commands.join + @redis.execute_command(@commands.join, true) @redis.read_socket @commands.clear end end -end \ No newline at end of file +end