lib/oxblood/pipeline.rb in oxblood-0.1.0.dev8 vs lib/oxblood/pipeline.rb in oxblood-0.1.0.dev9

@@ -1,29 +1,38 @@
-require 'oxblood/session'
+require 'oxblood/protocol'
+require 'oxblood/commands'
 
 module Oxblood
   # Redis pipeling class. Commands won't be send until {#sync} is called.
+  # Error responses won't be raises and should be checked manually in the
+  # responses array.
   # @see http://redis.io/topics/pipelining#redis-pipelining
   #
   # @example Basic workflow
   #   pipeline = Pipeline.new(connection)
   #   pipeline.echo('ping')
   #   pipeline.ping
   #   pipeline.echo('!')
   #   pipeline.sync # => ["ping", "PONG", "!"]
-  class Pipeline < Session
+  class Pipeline
+    include Oxblood::Commands
+
     def initialize(connection)
-      super
+      @connection = connection
       @commands = Array.new
     end
 
     # Sends all commands at once and reads responses
     # @return [Array] of responses
     def sync
-      serialized_commands = @commands.map { |c| serialize(*c) }
+      serialized_commands = @commands.map do |c|
+        Oxblood::Protocol.build_command(*c)
+      end
 
       @connection.socket.write(serialized_commands.join)
       @connection.read_responses(@commands.size)
+    ensure
+      @commands.clear
     end
 
     private
 
     def run(*command)