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

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

class RemovableDisposable:
    subject: Any = ...
    observer: Any = ...
    def __init__(self, subject: Any, observer: Any) -> None: ...
    def dispose(self) -> None: ...

class ReplaySubject(ObservableBase, Observer):
    buffer_size: Any = ...
    scheduler: Any = ...
    window: Any = ...
    queue: Any = ...
    observers: Any = ...
    is_stopped: bool = ...
    is_disposed: bool = ...
    has_error: bool = ...
    error: Any = ...
    lock: Any = ...
    def __init__(self, buffer_size: Optional[Any] = ..., window: Optional[Any] = ..., scheduler: Optional[Any] = ...) -> None: ...
    def check_disposed(self) -> None: ...
    def on_next(self, value: Any) -> None: ...
    def on_error(self, error: Any) -> None: ...
    def on_completed(self) -> None: ...
    def dispose(self) -> None: ...