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