lib/twitter/rest/api/direct_messages.rb in twitter-5.3.0 vs lib/twitter/rest/api/direct_messages.rb in twitter-5.3.1

@@ -1,9 +1,10 @@
 require 'twitter/arguments'
 require 'twitter/direct_message'
 require 'twitter/rest/api/utils'
 require 'twitter/user'
+require 'twitter/utils'
 
 module Twitter
   module REST
     module API
       module DirectMessages
@@ -86,10 +87,10 @@
         def direct_messages(*args)
           arguments = Twitter::Arguments.new(args)
           if arguments.empty?
             direct_messages_received(arguments.options)
           else
-            arguments.flatten.threaded_map do |id|
+            Twitter::Utils.parallel_map(arguments) do |id|
               direct_message(id, arguments.options)
             end
           end
         end