@redis = redis
@commands = []
end
-
- def get_response
- end
-
- def write(data)
- @commands << data
- write_and_read if @commands.size >= BUFFER_SIZE
+
+ def call_command(command)
+ @commands << command
end
-
- def finish
- write_and_read
- end
-
- def write_and_read
- @redis.write @commands.join
- @redis.read_socket
+
+ def execute
+ @redis.call_command(@commands)
@commands.clear
end
end
-end
\ No newline at end of file
+end