diff --git a/stubs/rx/backpressure/windowedobservable.pyi b/stubs/rx/backpressure/windowedobservable.pyi new file mode 100644 --- /dev/null +++ b/stubs/rx/backpressure/windowedobservable.pyi @@ -0,0 +1,25 @@ +# Stubs for rx.backpressure.windowedobservable (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from rx.core import ObservableBase, ObserverBase +from typing import Any, Optional + +log: Any + +class WindowedObserver(ObserverBase): + observer: Any = ... + observable: Any = ... + cancel: Any = ... + scheduler: Any = ... + received: int = ... + schedule_disposable: Any = ... + def __init__(self, observer: Any, observable: Any, cancel: Any, scheduler: Any) -> None: ... + def dispose(self) -> None: ... + +class WindowedObservable(ObservableBase): + source: Any = ... + window_size: Any = ... + scheduler: Any = ... + subscription: Any = ... + def __init__(self, source: Any, window_size: Any, scheduler: Optional[Any] = ...) -> None: ...