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

from rx.core import ObservableBase, Observer
from typing import Any, Optional

class StopAndWaitObserver(Observer):
    scheduler: Any = ...
    observer: Any = ...
    observable: Any = ...
    cancel: Any = ...
    is_disposed: bool = ...
    def __init__(self, observer: Any, observable: Any, cancel: Any, scheduler: Optional[Any] = ...) -> None: ...
    def on_completed(self) -> None: ...
    def on_error(self, error: Any) -> None: ...
    def on_next(self, value: Any) -> None: ...
    def dispose(self) -> None: ...

class StopAndWaitObservable(ObservableBase):
    scheduler: Any = ...
    source: Any = ...
    subscription: Any = ...
    def __init__(self, source: Any, scheduler: Optional[Any] = ...) -> None: ...