# 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] = ...): ...