diff --git a/stubs/rx/subjects/replaysubject.pyi b/stubs/rx/subjects/replaysubject.pyi new file mode 100644 --- /dev/null +++ b/stubs/rx/subjects/replaysubject.pyi @@ -0,0 +1,30 @@ +# 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: ...