# Stubs for rx.backpressure.pausable (Python 3)
#
# NOTE: This dynamically typed stub was automatically generated by stubgen.

from rx.core import ObservableBase
from typing import Any, Optional

class PausableObservable(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(self, pauser: Any): ...