diff --git a/stubs/rx/backpressure/pausablebuffered.pyi b/stubs/rx/backpressure/pausablebuffered.pyi new file mode 100644 --- /dev/null +++ b/stubs/rx/backpressure/pausablebuffered.pyi @@ -0,0 +1,18 @@ +# Stubs for rx.backpressure.pausablebuffered (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from rx.core import ObservableBase +from typing import Any, Optional + +def combine_latest_source(source: Any, subject: Any, result_selector: Any): ... + +class PausableBufferedObservable(ObservableBase): + source: Any = ... + controller: Any = ... + pauser: Any = ... + def __init__(self, source: Any, pauser: Optional[Any] = ...) -> None: ... + def pause(self) -> None: ... + def resume(self) -> None: ... + +def pausable_buffered(self, subject: Any): ...