diff --git a/stubs/rx/subjects/asyncsubject.pyi b/stubs/rx/subjects/asyncsubject.pyi new file mode 100644 --- /dev/null +++ b/stubs/rx/subjects/asyncsubject.pyi @@ -0,0 +1,22 @@ +# Stubs for rx.subjects.asyncsubject (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from .innersubscription import InnerSubscription +from rx.core import ObservableBase, Observer +from typing import Any + +class AsyncSubject(ObservableBase, Observer): + is_disposed: bool = ... + is_stopped: bool = ... + value: Any = ... + has_value: bool = ... + observers: Any = ... + exception: Any = ... + lock: Any = ... + def __init__(self) -> None: ... + def check_disposed(self) -> None: ... + def on_completed(self) -> None: ... + def on_error(self, exception: Any) -> None: ... + def on_next(self, value: Any) -> None: ... + def dispose(self) -> None: ...