# File lib/never_block/db/fibered_postgres_connection.rb, line 66 def process_command # make sure all commands are sent # before attempting to read return unless self.flush self.consume_input unless is_busy res, data = 0, [] while res != nil res = self.get_result data << res unless res.nil? end #let the fiber continue its work @fiber.resume(data.last) end end