diff --git a/stubs/rx/backpressure/controlledsubject.pyi b/stubs/rx/backpressure/controlledsubject.pyi new file mode 100644 --- /dev/null +++ b/stubs/rx/backpressure/controlledsubject.pyi @@ -0,0 +1,23 @@ +# Stubs for rx.backpressure.controlledsubject (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from rx.core import ObservableBase, Observer +from typing import Any, Optional + +class ControlledSubject(ObservableBase, Observer): + subject: Any = ... + enable_queue: Any = ... + queue: Any = ... + requested_count: int = ... + requested_disposable: Any = ... + error: Any = ... + has_failed: bool = ... + has_completed: bool = ... + scheduler: Any = ... + def __init__(self, enable_queue: bool = ..., scheduler: Optional[Any] = ...) -> None: ... + def on_completed(self) -> None: ... + def on_error(self, error: Any) -> None: ... + def on_next(self, value: Any) -> None: ... + def request(self, number: Any): ... + def dispose_current_request(self) -> None: ...