Asynchronous version of `starmap()` method.
(self, func, iterable, chunksize=None, callback=None,
error_callback=None)
| 375 | return self._map_async(func, iterable, starmapstar, chunksize).get() |
| 376 | |
| 377 | def starmap_async(self, func, iterable, chunksize=None, callback=None, |
| 378 | error_callback=None): |
| 379 | ''' |
| 380 | Asynchronous version of `starmap()` method. |
| 381 | ''' |
| 382 | return self._map_async(func, iterable, starmapstar, chunksize, |
| 383 | callback, error_callback) |
| 384 | |
| 385 | def _guarded_task_generation(self, result_job, func, iterable): |
| 386 | '''Provides a generator of tasks for imap and imap_unordered with |