Contents

require 'oxblood/command'

module Oxblood
  class Pipeline < Session
    def initialize(connection)
      super
      @commands = Array.new
    end

    def run(command)
      @commands << command
    end

    def sync
      @connection.write(@commands.join)
      @connection.read_responses(@commands.size)
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
oxblood-0.1.0.dev3	lib/oxblood/pipeline.rb
oxblood-0.1.0.dev2	lib/oxblood/pipeline.rb
oxblood-0.1.0.dev1	lib/oxblood/pipeline.rb