Show More
@@ -264,9 +264,12 class ParallelFunction(RemoteFunction): | |||||
264 | return r |
|
264 | return r | |
265 |
|
265 | |||
266 | def map(self, *sequences): |
|
266 | def map(self, *sequences): | |
267 |
"""call a function on each element of |
|
267 | """call a function on each element of one or more sequence(s) remotely. | |
268 | This should behave very much like the builtin map, but return an AsyncMapResult |
|
268 | This should behave very much like the builtin map, but return an AsyncMapResult | |
269 | if self.block is False. |
|
269 | if self.block is False. | |
|
270 | ||||
|
271 | That means it can take generators (will be cast to lists locally), | |||
|
272 | and mismatched sequence lengths will be padded with None. | |||
270 | """ |
|
273 | """ | |
271 | # set _mapping as a flag for use inside self.__call__ |
|
274 | # set _mapping as a flag for use inside self.__call__ | |
272 | self._mapping = True |
|
275 | self._mapping = True |
General Comments 0
You need to be logged in to leave comments.
Login now