lib/oxblood/pipeline.rb in oxblood-0.1.0.dev6 vs lib/oxblood/pipeline.rb in oxblood-0.1.0.dev7

- old
+ new

@@ -18,10 +18,11 @@ # Sends all commands at once and reads responses # @return [Array] of responses def sync serialized_commands = @commands.map { |c| serialize(*c) } - @connection.write(serialized_commands.join) + + @connection.socket.write(serialized_commands.join) @connection.read_responses(@commands.size) end private