diff --git a/stubs/rx/joins/joinobserver.pyi b/stubs/rx/joins/joinobserver.pyi new file mode 100644 --- /dev/null +++ b/stubs/rx/joins/joinobserver.pyi @@ -0,0 +1,19 @@ +# Stubs for rx.joins.joinobserver (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from rx.core import ObserverBase +from typing import Any + +class JoinObserver(ObserverBase): + source: Any = ... + on_error: Any = ... + queue: Any = ... + active_plans: Any = ... + subscription: Any = ... + is_disposed: bool = ... + def __init__(self, source: Any, on_error: Any) -> None: ... + def add_active_plan(self, active_plan: Any) -> None: ... + def subscribe(self) -> None: ... + def remove_active_plan(self, active_plan: Any) -> None: ... + def dispose(self) -> None: ...