fix: Add MapResult type (#3228)

This commit is contained in:
秋葉
2019-09-12 00:20:40 +08:00
committed by Sebastian Rittau
parent 686e21d330
commit 5ccf017ca0

View File

@@ -17,6 +17,8 @@ class ApplyResult(Generic[_T]):
# alias created during issue #17805
AsyncResult = ApplyResult
class MapResult(ApplyResult[List[_T]]): ...
_IMIT = TypeVar('_IMIT', bound=IMapIterator)
class IMapIterator(Iterator[_T]):
@@ -50,7 +52,7 @@ class Pool(ContextManager[Pool]):
iterable: Iterable[_S] = ...,
chunksize: Optional[int] = ...,
callback: Optional[Callable[[_T], None]] = ...,
error_callback: Optional[Callable[[BaseException], None]] = ...) -> AsyncResult[List[_T]]: ...
error_callback: Optional[Callable[[BaseException], None]] = ...) -> MapResult[List[_T]]: ...
def imap(self,
func: Callable[[_S], _T],
iterable: Iterable[_S] = ...,