diff --git a/stubs/rx/backpressure/controlledobservable.pyi b/stubs/rx/backpressure/controlledobservable.pyi new file mode 100644 --- /dev/null +++ b/stubs/rx/backpressure/controlledobservable.pyi @@ -0,0 +1,15 @@ +# Stubs for rx.backpressure.controlledobservable (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from .controlledsubject import ControlledSubject +from rx.core import ObservableBase +from typing import Any, Optional + +class ControlledObservable(ObservableBase): + subject: Any = ... + source: Any = ... + def __init__(self, source: Any, enable_queue: Any, scheduler: Optional[Any] = ...) -> None: ... + def request(self, number_of_items: Any): ... + +def controlled(self, enable_queue: bool = ..., scheduler: Optional[Any] = ...): ...