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

from .activeplan import ActivePlan
from .joinobserver import JoinObserver
from typing import Any

class Plan:
    expression: Any = ...
    selector: Any = ...
    def __init__(self, expression: Any, selector: Any) -> None: ...
    def activate(self, external_subscriptions: Any, observer: Any, deactivate: Any): ...
    def plan_create_observer(self, external_subscriptions: Any, observable: Any, on_error: Any): ...