diff --git a/stubs/rx/backpressure/stopandwaitobservable.pyi b/stubs/rx/backpressure/stopandwaitobservable.pyi new file mode 100644 --- /dev/null +++ b/stubs/rx/backpressure/stopandwaitobservable.pyi @@ -0,0 +1,24 @@ +# 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: ...