VimPlug/typeshed
1
0
Fork 0
mirror of https://github.com/davidhalter/typeshed.git synced 2025-12-09 13:34:58 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

multiprocessing: audit callback annotations (#8178)

Browse Source
This commit is contained in:
Alex Waygood
2022-06-26 13:15:26 +01:00
committed by GitHub
parent 74bd0d962b
commit ca44b893e3
1 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
stdlib/multiprocessing/pool.pyi
View File

@@ -16,14 +16,14 @@ _T = TypeVar("_T")
class ApplyResult(Generic[_T]):
if sys.version_info >= (3, 8):
def __init__(
self, pool: Pool, callback: Callable[[_T], None] | None, error_callback: Callable[[BaseException], None] | None
self, pool: Pool, callback: Callable[[_T], object] | None, error_callback: Callable[[BaseException], object] | None
) -> None: ...
else:
def __init__(
self,
cache: dict[int, ApplyResult[Any]],
callback: Callable[[_T], None] | None,
error_callback: Callable[[BaseException], None] | None,
callback: Callable[[_T], object] | None,
error_callback: Callable[[BaseException], object] | None,
) -> None: ...
def get(self, timeout: float | None = ...) -> _T: ...
@@ -43,8 +43,8 @@ class MapResult(ApplyResult[list[_T]]):
pool: Pool,
chunksize: int,
length: int,
callback: Callable[[list[_T]], None] | None,
error_callback: Callable[[BaseException], None] | None,
callback: Callable[[list[_T]], object] | None,
error_callback: Callable[[BaseException], object] | None,
) -> None: ...
else:
def __init__(
@@ -52,8 +52,8 @@ class MapResult(ApplyResult[list[_T]]):
cache: dict[int, ApplyResult[Any]],
chunksize: int,
length: int,
callback: Callable[[list[_T]], None] | None,
error_callback: Callable[[BaseException], None] | None,
callback: Callable[[list[_T]], object] | None,
error_callback: Callable[[BaseException], object] | None,
) -> None: ...
class IMapIterator(Iterator[_T]):
@@ -83,8 +83,8 @@ class Pool:
func: Callable[..., _T],
args: Iterable[Any] = ...,
kwds: Mapping[str, Any] = ...,
callback: Callable[[_T], None] | None = ...,
error_callback: Callable[[BaseException], None] | None = ...,
callback: Callable[[_T], object] | None = ...,
error_callback: Callable[[BaseException], object] | None = ...,
) -> AsyncResult[_T]: ...
def map(self, func: Callable[[_S], _T], iterable: Iterable[_S], chunksize: int | None = ...) -> list[_T]: ...
def map_async(
@@ -92,8 +92,8 @@ class Pool:
func: Callable[[_S], _T],
iterable: Iterable[_S],
chunksize: int | None = ...,
callback: Callable[[_T], None] | None = ...,
error_callback: Callable[[BaseException], None] | None = ...,
callback: Callable[[_T], object] | None = ...,
error_callback: Callable[[BaseException], object] | None = ...,
) -> MapResult[_T]: ...
def imap(self, func: Callable[[_S], _T], iterable: Iterable[_S], chunksize: int | None = ...) -> IMapIterator[_T]: ...
def imap_unordered(
@@ -105,8 +105,8 @@ class Pool:
func: Callable[..., _T],
iterable: Iterable[Iterable[Any]],
chunksize: int | None = ...,
callback: Callable[[_T], None] | None = ...,
error_callback: Callable[[BaseException], None] | None = ...,
callback: Callable[[_T], object] | None = ...,
error_callback: Callable[[BaseException], object] | None = ...,
) -> AsyncResult[list[_T]]: ...
def close(self) -> None: ...
def terminate(self) -> None: ...