# 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: ...