# Stubs for rx.concurrency.threadpoolscheduler (Python 3)
#
# NOTE: This dynamically typed stub was automatically generated by stubgen.

from .newthreadscheduler import NewThreadScheduler
from typing import Any, Optional

class ThreadPoolScheduler(NewThreadScheduler):
    class ThreadPoolThread:
        run: Any = ...
        future: Any = ...
        executor: Any = ...
        def __init__(self, executor: Any, run: Any) -> None: ...
        def start(self) -> None: ...
        def cancel(self) -> None: ...
    executor: Any = ...
    def __init__(self, max_workers: Optional[Any] = ...) -> None: ...
    def thread_factory(self, target: Any, *args: Any): ...

thread_pool_scheduler: Any