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

from .scheduleditem import ScheduledItem
from .schedulerbase import SchedulerBase
from typing import Any, Optional

log: Any

class Trampoline:
    @classmethod
    def run(cls, queue: Any) -> None: ...

class CurrentThreadScheduler(SchedulerBase):
    queues: Any = ...
    lock: Any = ...
    def __init__(self) -> None: ...
    def schedule(self, action: Any, state: Optional[Any] = ...): ...
    queue: Any = ...
    def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ...
    def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ...
    def get_queue(self): ...
    def set_queue(self, queue: Any) -> None: ...
    def schedule_required(self): ...
    def ensure_trampoline(self, action: Any): ...

current_thread_scheduler: Any