# 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: ...