diff --git a/light9/vidref/videorecorder.py b/light9/vidref/videorecorder.py --- a/light9/vidref/videorecorder.py +++ b/light9/vidref/videorecorder.py @@ -9,8 +9,8 @@ gi.require_version('GstBase', '1.0') from PIL import Image from gi.repository import Gst -from rx.subjects import BehaviorSubject -from twisted.internet import defer, threads +from rx.subject import BehaviorSubject +from twisted.internet import threads import moviepy.editor import numpy diff --git a/requirements.txt b/requirements.txt --- a/requirements.txt +++ b/requirements.txt @@ -17,7 +17,7 @@ python-dateutil==2.6.0 pyusb==1.0.0 rdflib==4.2.2 requests==2.22.0 -rx==1.6.1 +git+https://github.com/ReactiveX/RxPY.git@6deb66e827f34a88b4605773d7671322b9cbbd08#egg=rx scipy==1.3.0 service_identity==18.1.0 statprof==0.1.2 diff --git a/stubs/rx/__init__.pyi b/stubs/rx/__init__.pyi deleted file mode 100644 --- a/stubs/rx/__init__.pyi +++ /dev/null @@ -1,10 +0,0 @@ -# Stubs for rx (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .core import Observable, Observer -from .core.anonymousobservable import AnonymousObservable -from .core.anonymousobserver import AnonymousObserver -from typing import Any - -config: Any diff --git a/stubs/rx/backpressure/__init__.pyi b/stubs/rx/backpressure/__init__.pyi deleted file mode 100644 --- a/stubs/rx/backpressure/__init__.pyi +++ /dev/null @@ -1,4 +0,0 @@ -# Stubs for rx.backpressure (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - diff --git a/stubs/rx/backpressure/controlledobservable.pyi b/stubs/rx/backpressure/controlledobservable.pyi deleted file mode 100644 --- a/stubs/rx/backpressure/controlledobservable.pyi +++ /dev/null @@ -1,15 +0,0 @@ -# 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] = ...): ... diff --git a/stubs/rx/backpressure/controlledsubject.pyi b/stubs/rx/backpressure/controlledsubject.pyi deleted file mode 100644 --- a/stubs/rx/backpressure/controlledsubject.pyi +++ /dev/null @@ -1,23 +0,0 @@ -# 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: ... diff --git a/stubs/rx/backpressure/pausable.pyi b/stubs/rx/backpressure/pausable.pyi deleted file mode 100644 --- a/stubs/rx/backpressure/pausable.pyi +++ /dev/null @@ -1,16 +0,0 @@ -# Stubs for rx.backpressure.pausable (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.core import ObservableBase -from typing import Any, Optional - -class PausableObservable(ObservableBase): - source: Any = ... - controller: Any = ... - pauser: Any = ... - def __init__(self, source: Any, pauser: Optional[Any] = ...) -> None: ... - def pause(self) -> None: ... - def resume(self) -> None: ... - -def pausable(self, pauser: Any): ... diff --git a/stubs/rx/backpressure/pausablebuffered.pyi b/stubs/rx/backpressure/pausablebuffered.pyi deleted file mode 100644 --- a/stubs/rx/backpressure/pausablebuffered.pyi +++ /dev/null @@ -1,18 +0,0 @@ -# Stubs for rx.backpressure.pausablebuffered (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.core import ObservableBase -from typing import Any, Optional - -def combine_latest_source(source: Any, subject: Any, result_selector: Any): ... - -class PausableBufferedObservable(ObservableBase): - source: Any = ... - controller: Any = ... - pauser: Any = ... - def __init__(self, source: Any, pauser: Optional[Any] = ...) -> None: ... - def pause(self) -> None: ... - def resume(self) -> None: ... - -def pausable_buffered(self, subject: Any): ... diff --git a/stubs/rx/backpressure/stopandwait.pyi b/stubs/rx/backpressure/stopandwait.pyi deleted file mode 100644 --- a/stubs/rx/backpressure/stopandwait.pyi +++ /dev/null @@ -1,8 +0,0 @@ -# Stubs for rx.backpressure.stopandwait (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .controlledobservable import ControlledObservable -from .stopandwaitobservable import StopAndWaitObservable - -def stop_and_wait(self): ... diff --git a/stubs/rx/backpressure/stopandwaitobservable.pyi b/stubs/rx/backpressure/stopandwaitobservable.pyi deleted file mode 100644 --- a/stubs/rx/backpressure/stopandwaitobservable.pyi +++ /dev/null @@ -1,24 +0,0 @@ -# Stubs for rx.backpressure.stopandwaitobservable (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.core import ObservableBase, Observer -from typing import Any, Optional - -class StopAndWaitObserver(Observer): - scheduler: Any = ... - observer: Any = ... - observable: Any = ... - cancel: Any = ... - is_disposed: bool = ... - def __init__(self, observer: Any, observable: Any, cancel: Any, scheduler: Optional[Any] = ...) -> None: ... - def on_completed(self) -> None: ... - def on_error(self, error: Any) -> None: ... - def on_next(self, value: Any) -> None: ... - def dispose(self) -> None: ... - -class StopAndWaitObservable(ObservableBase): - scheduler: Any = ... - source: Any = ... - subscription: Any = ... - def __init__(self, source: Any, scheduler: Optional[Any] = ...) -> None: ... diff --git a/stubs/rx/backpressure/windowed.pyi b/stubs/rx/backpressure/windowed.pyi deleted file mode 100644 --- a/stubs/rx/backpressure/windowed.pyi +++ /dev/null @@ -1,9 +0,0 @@ -# Stubs for rx.backpressure.windowed (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .controlledobservable import ControlledObservable -from .windowedobservable import WindowedObservable -from typing import Any - -def windowed(self, window_size: Any): ... diff --git a/stubs/rx/backpressure/windowedobservable.pyi b/stubs/rx/backpressure/windowedobservable.pyi deleted file mode 100644 --- a/stubs/rx/backpressure/windowedobservable.pyi +++ /dev/null @@ -1,25 +0,0 @@ -# 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: ... diff --git a/stubs/rx/concurrency/__init__.pyi b/stubs/rx/concurrency/__init__.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/__init__.pyi +++ /dev/null @@ -1,15 +0,0 @@ -# Stubs for rx.concurrency (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .catchscheduler import CatchScheduler -from .currentthreadscheduler import CurrentThreadScheduler, current_thread_scheduler -from .eventloopscheduler import EventLoopScheduler -from .historicalscheduler import HistoricalScheduler -from .immediatescheduler import ImmediateScheduler, immediate_scheduler -from .mainloopscheduler import AsyncIOScheduler, EventLetEventScheduler, GEventScheduler, GtkScheduler, IOLoopScheduler, PyGameScheduler, QtScheduler, TkinterScheduler, TwistedScheduler, WxScheduler -from .newthreadscheduler import NewThreadScheduler, new_thread_scheduler -from .scheduleditem import ScheduledItem -from .threadpoolscheduler import ThreadPoolScheduler, thread_pool_scheduler -from .timeoutscheduler import TimeoutScheduler, timeout_scheduler -from .virtualtimescheduler import VirtualTimeScheduler diff --git a/stubs/rx/concurrency/catchscheduler.pyi b/stubs/rx/concurrency/catchscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/catchscheduler.pyi +++ /dev/null @@ -1,15 +0,0 @@ -# Stubs for rx.concurrency.catchscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import abc -from .schedulerbase import SchedulerBase -from typing import Any, Optional - -class CatchScheduler(SchedulerBase, metaclass=abc.ABCMeta): - def __init__(self, scheduler: Any, handler: Any) -> None: ... - def local_now(self): ... - def schedule_now(self, state: Any, action: Any): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_periodic(self, period: Any, action: Any, state: Optional[Any] = ...): ... diff --git a/stubs/rx/concurrency/currentthreadscheduler.pyi b/stubs/rx/concurrency/currentthreadscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/currentthreadscheduler.pyi +++ /dev/null @@ -1,28 +0,0 @@ -# Stubs for rx.concurrency.currentthreadscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .scheduleditem import ScheduledItem -from .schedulerbase import SchedulerBase -from typing import Any, Optional - -log: Any - -class Trampoline: - @classmethod - def run(cls, queue: Any) -> None: ... - -class CurrentThreadScheduler(SchedulerBase): - queues: Any = ... - lock: Any = ... - def __init__(self) -> None: ... - def schedule(self, action: Any, state: Optional[Any] = ...): ... - queue: Any = ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def get_queue(self): ... - def set_queue(self, queue: Any) -> None: ... - def schedule_required(self): ... - def ensure_trampoline(self, action: Any): ... - -current_thread_scheduler: Any diff --git a/stubs/rx/concurrency/eventloopscheduler.pyi b/stubs/rx/concurrency/eventloopscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/eventloopscheduler.pyi +++ /dev/null @@ -1,32 +0,0 @@ -# Stubs for rx.concurrency.eventloopscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .schedulerbase import SchedulerBase -from rx.core import Disposable -from typing import Any, Optional - -log: Any - -class EventLoopScheduler(SchedulerBase, Disposable): - is_disposed: bool = ... - lock: Any = ... - thread_factory: Any = ... - thread: Any = ... - timer: Any = ... - condition: Any = ... - queue: Any = ... - ready_list: Any = ... - next_item: Any = ... - exit_if_empty: Any = ... - def __init__(self, thread_factory: Optional[Any] = ..., exit_if_empty: bool = ...) -> None: ... - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_periodic(self, period: Any, action: Any, state: Optional[Any] = ...): ... - def ensure_thread(self) -> None: ... - def run(self) -> None: ... - def dispose(self) -> None: ... - def tick(self, item: Any) -> None: ... - -event_loop_scheduler: Any diff --git a/stubs/rx/concurrency/historicalscheduler.pyi b/stubs/rx/concurrency/historicalscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/historicalscheduler.pyi +++ /dev/null @@ -1,15 +0,0 @@ -# Stubs for rx.concurrency.historicalscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .virtualtimescheduler import VirtualTimeScheduler -from typing import Any, Optional - -class HistoricalScheduler(VirtualTimeScheduler): - def __init__(self, initial_clock: Optional[Any] = ..., comparer: Optional[Any] = ...) -> None: ... - @property - def now(self): ... - @staticmethod - def add(absolute: Any, relative: Any): ... - def to_datetime_offset(self, absolute: Any): ... - def to_relative(self, timespan: Any): ... diff --git a/stubs/rx/concurrency/immediatescheduler.pyi b/stubs/rx/concurrency/immediatescheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/immediatescheduler.pyi +++ /dev/null @@ -1,13 +0,0 @@ -# Stubs for rx.concurrency.immediatescheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .schedulerbase import SchedulerBase -from typing import Any, Optional - -class ImmediateScheduler(SchedulerBase): - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - -immediate_scheduler: Any diff --git a/stubs/rx/concurrency/mainloopscheduler/__init__.pyi b/stubs/rx/concurrency/mainloopscheduler/__init__.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/mainloopscheduler/__init__.pyi +++ /dev/null @@ -1,14 +0,0 @@ -# Stubs for rx.concurrency.mainloopscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .asyncioscheduler import AsyncIOScheduler -from .eventletscheduler import EventLetEventScheduler -from .geventscheduler import GEventScheduler -from .gtkscheduler import GtkScheduler -from .ioloopscheduler import IOLoopScheduler -from .pygamescheduler import PyGameScheduler -from .qtscheduler import QtScheduler -from .tkinterscheduler import TkinterScheduler -from .twistedscheduler import TwistedScheduler -from .wxscheduler import WxScheduler diff --git a/stubs/rx/concurrency/mainloopscheduler/asyncioscheduler.pyi b/stubs/rx/concurrency/mainloopscheduler/asyncioscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/mainloopscheduler/asyncioscheduler.pyi +++ /dev/null @@ -1,18 +0,0 @@ -# Stubs for rx.concurrency.mainloopscheduler.asyncioscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.concurrency.schedulerbase import SchedulerBase -from typing import Any, Optional - -asyncio: Any -log: Any - -class AsyncIOScheduler(SchedulerBase): - loop: Any = ... - def __init__(self, loop: Optional[Any] = ...) -> None: ... - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - @property - def now(self): ... diff --git a/stubs/rx/concurrency/mainloopscheduler/eventletscheduler.pyi b/stubs/rx/concurrency/mainloopscheduler/eventletscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/mainloopscheduler/eventletscheduler.pyi +++ /dev/null @@ -1,17 +0,0 @@ -# Stubs for rx.concurrency.mainloopscheduler.eventletscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.concurrency.schedulerbase import SchedulerBase -from typing import Any, Optional - -eventlet: Any -log: Any - -class EventLetEventScheduler(SchedulerBase): - def __init__(self) -> None: ... - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - @property - def now(self): ... diff --git a/stubs/rx/concurrency/mainloopscheduler/geventscheduler.pyi b/stubs/rx/concurrency/mainloopscheduler/geventscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/mainloopscheduler/geventscheduler.pyi +++ /dev/null @@ -1,17 +0,0 @@ -# Stubs for rx.concurrency.mainloopscheduler.geventscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.concurrency.schedulerbase import SchedulerBase -from typing import Any, Optional - -gevent: Any -log: Any - -class GEventScheduler(SchedulerBase): - def __init__(self) -> None: ... - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - @property - def now(self): ... diff --git a/stubs/rx/concurrency/mainloopscheduler/gtkscheduler.pyi b/stubs/rx/concurrency/mainloopscheduler/gtkscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/mainloopscheduler/gtkscheduler.pyi +++ /dev/null @@ -1,12 +0,0 @@ -# Stubs for rx.concurrency.mainloopscheduler.gtkscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.concurrency.schedulerbase import SchedulerBase -from typing import Any, Optional - -class GtkScheduler(SchedulerBase): - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_periodic(self, period: Any, action: Any, state: Optional[Any] = ...): ... diff --git a/stubs/rx/concurrency/mainloopscheduler/ioloopscheduler.pyi b/stubs/rx/concurrency/mainloopscheduler/ioloopscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/mainloopscheduler/ioloopscheduler.pyi +++ /dev/null @@ -1,17 +0,0 @@ -# Stubs for rx.concurrency.mainloopscheduler.ioloopscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.concurrency.schedulerbase import SchedulerBase -from typing import Any, Optional - -log: Any - -class IOLoopScheduler(SchedulerBase): - loop: Any = ... - def __init__(self, loop: Optional[Any] = ...) -> None: ... - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - @property - def now(self): ... diff --git a/stubs/rx/concurrency/mainloopscheduler/pygamescheduler.pyi b/stubs/rx/concurrency/mainloopscheduler/pygamescheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/mainloopscheduler/pygamescheduler.pyi +++ /dev/null @@ -1,21 +0,0 @@ -# Stubs for rx.concurrency.mainloopscheduler.pygamescheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.concurrency.schedulerbase import SchedulerBase -from typing import Any, Optional - -pygame: Any -log: Any - -class PyGameScheduler(SchedulerBase): - timer: Any = ... - event_id: Any = ... - queue: Any = ... - def __init__(self, event_id: Optional[Any] = ...) -> None: ... - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def run(self) -> None: ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - @property - def now(self): ... diff --git a/stubs/rx/concurrency/mainloopscheduler/qtscheduler.pyi b/stubs/rx/concurrency/mainloopscheduler/qtscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/mainloopscheduler/qtscheduler.pyi +++ /dev/null @@ -1,16 +0,0 @@ -# Stubs for rx.concurrency.mainloopscheduler.qtscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.concurrency.schedulerbase import SchedulerBase -from typing import Any, Optional - -log: Any - -class QtScheduler(SchedulerBase): - qtcore: Any = ... - def __init__(self, qtcore: Any) -> None: ... - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_periodic(self, period: Any, action: Any, state: Optional[Any] = ...): ... diff --git a/stubs/rx/concurrency/mainloopscheduler/tkinterscheduler.pyi b/stubs/rx/concurrency/mainloopscheduler/tkinterscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/mainloopscheduler/tkinterscheduler.pyi +++ /dev/null @@ -1,13 +0,0 @@ -# Stubs for rx.concurrency.mainloopscheduler.tkinterscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.concurrency.schedulerbase import SchedulerBase -from typing import Any, Optional - -class TkinterScheduler(SchedulerBase): - master: Any = ... - def __init__(self, master: Any) -> None: ... - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... diff --git a/stubs/rx/concurrency/mainloopscheduler/twistedscheduler.pyi b/stubs/rx/concurrency/mainloopscheduler/twistedscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/mainloopscheduler/twistedscheduler.pyi +++ /dev/null @@ -1,17 +0,0 @@ -# Stubs for rx.concurrency.mainloopscheduler.twistedscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.concurrency.schedulerbase import SchedulerBase -from typing import Any, Optional - -log: Any - -class TwistedScheduler(SchedulerBase): - reactor: Any = ... - def __init__(self, reactor: Any) -> None: ... - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - @property - def now(self): ... diff --git a/stubs/rx/concurrency/mainloopscheduler/wxscheduler.pyi b/stubs/rx/concurrency/mainloopscheduler/wxscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/mainloopscheduler/wxscheduler.pyi +++ /dev/null @@ -1,18 +0,0 @@ -# Stubs for rx.concurrency.mainloopscheduler.wxscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.concurrency.schedulerbase import SchedulerBase -from typing import Any, Optional - -log: Any - -class WxScheduler(SchedulerBase): - wx: Any = ... - callback: Any = ... - def __init__(self, wx: Any) -> None: ... - def cancel_all(self) -> None: ... - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_periodic(self, period: Any, action: Any, state: Optional[Any] = ...): ... diff --git a/stubs/rx/concurrency/newthreadscheduler.pyi b/stubs/rx/concurrency/newthreadscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/newthreadscheduler.pyi +++ /dev/null @@ -1,19 +0,0 @@ -# Stubs for rx.concurrency.newthreadscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .eventloopscheduler import EventLoopScheduler -from .schedulerbase import SchedulerBase -from typing import Any, Optional - -log: Any - -class NewThreadScheduler(SchedulerBase): - thread_factory: Any = ... - def __init__(self, thread_factory: Optional[Any] = ...) -> None: ... - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_periodic(self, period: Any, action: Any, state: Optional[Any] = ...): ... - -new_thread_scheduler: Any diff --git a/stubs/rx/concurrency/scheduleditem.pyi b/stubs/rx/concurrency/scheduleditem.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/scheduleditem.pyi +++ /dev/null @@ -1,21 +0,0 @@ -# Stubs for rx.concurrency.scheduleditem (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -def default_sub_comparer(x: Any, y: Any): ... - -class ScheduledItem: - scheduler: Any = ... - state: Any = ... - action: Any = ... - duetime: Any = ... - disposable: Any = ... - def __init__(self, scheduler: Any, state: Any, action: Any, duetime: Any) -> None: ... - def invoke(self) -> None: ... - def cancel(self) -> None: ... - def is_cancelled(self): ... - def __lt__(self, other: Any): ... - def __gt__(self, other: Any): ... - def __eq__(self, other: Any): ... diff --git a/stubs/rx/concurrency/scheduleperiodic.pyi b/stubs/rx/concurrency/scheduleperiodic.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/scheduleperiodic.pyi +++ /dev/null @@ -1,10 +0,0 @@ -# Stubs for rx.concurrency.scheduleperiodic (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional - -class SchedulePeriodic: - def __init__(self, scheduler: Any, period: Any, action: Any, state: Optional[Any] = ...) -> None: ... - def tick(self, scheduler: Any, command: Any) -> None: ... - def start(self): ... diff --git a/stubs/rx/concurrency/schedulerbase.pyi b/stubs/rx/concurrency/schedulerbase.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/schedulerbase.pyi +++ /dev/null @@ -1,21 +0,0 @@ -# Stubs for rx.concurrency.schedulerbase (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -import abc -from rx.core import Scheduler -from typing import Any, Optional - -class SchedulerBase(Scheduler, metaclass=abc.ABCMeta): - def invoke_action(self, action: Any, state: Optional[Any] = ...): ... - def schedule_periodic(self, period: Any, action: Any, state: Optional[Any] = ...): ... - @property - def now(self): ... - @classmethod - def to_relative(cls, timespan: Any): ... - @classmethod - def to_datetime(cls, duetime: Any): ... - @classmethod - def to_timedelta(cls, timespan: Any): ... - @classmethod - def normalize(cls, timespan: Any): ... diff --git a/stubs/rx/concurrency/threadpoolscheduler.pyi b/stubs/rx/concurrency/threadpoolscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/threadpoolscheduler.pyi +++ /dev/null @@ -1,20 +0,0 @@ -# Stubs for rx.concurrency.threadpoolscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .newthreadscheduler import NewThreadScheduler -from typing import Any, Optional - -class ThreadPoolScheduler(NewThreadScheduler): - class ThreadPoolThread: - run: Any = ... - future: Any = ... - executor: Any = ... - def __init__(self, executor: Any, run: Any) -> None: ... - def start(self) -> None: ... - def cancel(self) -> None: ... - executor: Any = ... - def __init__(self, max_workers: Optional[Any] = ...) -> None: ... - def thread_factory(self, target: Any, *args: Any): ... - -thread_pool_scheduler: Any diff --git a/stubs/rx/concurrency/timeoutscheduler.pyi b/stubs/rx/concurrency/timeoutscheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/timeoutscheduler.pyi +++ /dev/null @@ -1,15 +0,0 @@ -# Stubs for rx.concurrency.timeoutscheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .schedulerbase import SchedulerBase -from typing import Any, Optional - -log: Any - -class TimeoutScheduler(SchedulerBase): - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - -timeout_scheduler: Any diff --git a/stubs/rx/concurrency/virtualtimescheduler.pyi b/stubs/rx/concurrency/virtualtimescheduler.pyi deleted file mode 100644 --- a/stubs/rx/concurrency/virtualtimescheduler.pyi +++ /dev/null @@ -1,30 +0,0 @@ -# Stubs for rx.concurrency.virtualtimescheduler (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .scheduleditem import ScheduledItem -from .scheduleperiodic import SchedulePeriodic -from .schedulerbase import SchedulerBase -from typing import Any, Optional - -log: Any - -class VirtualTimeScheduler(SchedulerBase): - clock: Any = ... - is_enabled: bool = ... - queue: Any = ... - def __init__(self, initial_clock: int = ...) -> None: ... - @property - def now(self): ... - def schedule(self, action: Any, state: Optional[Any] = ...): ... - def schedule_relative(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_absolute(self, duetime: Any, action: Any, state: Optional[Any] = ...): ... - def schedule_periodic(self, period: Any, action: Any, state: Optional[Any] = ...): ... - def start(self) -> None: ... - def stop(self) -> None: ... - def advance_to(self, time: Any) -> None: ... - def advance_by(self, time: Any): ... - def sleep(self, time: Any) -> None: ... - def get_next(self): ... - @staticmethod - def add(absolute: Any, relative: Any) -> None: ... diff --git a/stubs/rx/disposables/__init__.pyi b/stubs/rx/disposables/__init__.pyi deleted file mode 100644 --- a/stubs/rx/disposables/__init__.pyi +++ /dev/null @@ -1,12 +0,0 @@ -# Stubs for rx.disposables (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .anonymousdisposable import AnonymousDisposable -from .booleandisposable import BooleanDisposable -from .compositedisposable import CompositeDisposable -from .multipleassignmentdisposable import MultipleAssignmentDisposable -from .refcountdisposable import RefCountDisposable -from .scheduleddisposable import ScheduledDisposable -from .serialdisposable import SerialDisposable -from .singleassignmentdisposable import SingleAssignmentDisposable diff --git a/stubs/rx/disposables/anonymousdisposable.pyi b/stubs/rx/disposables/anonymousdisposable.pyi deleted file mode 100644 --- a/stubs/rx/disposables/anonymousdisposable.pyi +++ /dev/null @@ -1,17 +0,0 @@ -# Stubs for rx.disposables.anonymousdisposable (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.core import Disposable -from typing import Any, Optional - -class AnonymousDisposable(Disposable): - is_disposed: bool = ... - action: Any = ... - lock: Any = ... - def __init__(self, action: Optional[Any] = ...) -> None: ... - def dispose(self) -> None: ... - @classmethod - def empty(cls): ... - @classmethod - def create(cls, action: Any): ... diff --git a/stubs/rx/disposables/booleandisposable.pyi b/stubs/rx/disposables/booleandisposable.pyi deleted file mode 100644 --- a/stubs/rx/disposables/booleandisposable.pyi +++ /dev/null @@ -1,12 +0,0 @@ -# Stubs for rx.disposables.booleandisposable (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.core import Disposable -from typing import Any - -class BooleanDisposable(Disposable): - is_disposed: bool = ... - lock: Any = ... - def __init__(self) -> None: ... - def dispose(self) -> None: ... diff --git a/stubs/rx/disposables/compositedisposable.pyi b/stubs/rx/disposables/compositedisposable.pyi deleted file mode 100644 --- a/stubs/rx/disposables/compositedisposable.pyi +++ /dev/null @@ -1,21 +0,0 @@ -# Stubs for rx.disposables.compositedisposable (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.core import Disposable -from typing import Any - -class CompositeDisposable(Disposable): - disposables: Any = ... - is_disposed: bool = ... - lock: Any = ... - def __init__(self, *args: Any) -> None: ... - def add(self, item: Any) -> None: ... - def remove(self, item: Any): ... - def dispose(self) -> None: ... - def clear(self) -> None: ... - def contains(self, item: Any): ... - def to_list(self): ... - def __len__(self): ... - @property - def length(self): ... diff --git a/stubs/rx/disposables/multipleassignmentdisposable.pyi b/stubs/rx/disposables/multipleassignmentdisposable.pyi deleted file mode 100644 --- a/stubs/rx/disposables/multipleassignmentdisposable.pyi +++ /dev/null @@ -1,16 +0,0 @@ -# Stubs for rx.disposables.multipleassignmentdisposable (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.core import Disposable -from typing import Any - -class MultipleAssignmentDisposable(Disposable): - current: Any = ... - is_disposed: bool = ... - lock: Any = ... - def __init__(self) -> None: ... - def get_disposable(self): ... - def set_disposable(self, value: Any) -> None: ... - disposable: Any = ... - def dispose(self) -> None: ... diff --git a/stubs/rx/disposables/refcountdisposable.pyi b/stubs/rx/disposables/refcountdisposable.pyi deleted file mode 100644 --- a/stubs/rx/disposables/refcountdisposable.pyi +++ /dev/null @@ -1,24 +0,0 @@ -# Stubs for rx.disposables.refcountdisposable (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.core import Disposable -from typing import Any - -class RefCountDisposable(Disposable): - class InnerDisposable(Disposable): - parent: Any = ... - is_disposed: bool = ... - lock: Any = ... - def __init__(self, parent: Any) -> None: ... - def dispose(self) -> None: ... - underlying_disposable: Any = ... - is_primary_disposed: bool = ... - is_disposed: bool = ... - lock: Any = ... - count: int = ... - def __init__(self, disposable: Any) -> None: ... - def dispose(self) -> None: ... - def release(self) -> None: ... - @property - def disposable(self): ... diff --git a/stubs/rx/disposables/scheduleddisposable.pyi b/stubs/rx/disposables/scheduleddisposable.pyi deleted file mode 100644 --- a/stubs/rx/disposables/scheduleddisposable.pyi +++ /dev/null @@ -1,14 +0,0 @@ -# Stubs for rx.disposables.scheduleddisposable (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.core import Disposable -from typing import Any - -class ScheduledDisposable(Disposable): - scheduler: Any = ... - disposable: Any = ... - is_disposed: bool = ... - lock: Any = ... - def __init__(self, scheduler: Any, disposable: Any) -> None: ... - def dispose(self) -> None: ... diff --git a/stubs/rx/disposables/serialdisposable.pyi b/stubs/rx/disposables/serialdisposable.pyi deleted file mode 100644 --- a/stubs/rx/disposables/serialdisposable.pyi +++ /dev/null @@ -1,16 +0,0 @@ -# Stubs for rx.disposables.serialdisposable (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.core import Disposable -from typing import Any - -class SerialDisposable(Disposable): - current: Any = ... - is_disposed: bool = ... - lock: Any = ... - def __init__(self) -> None: ... - def get_disposable(self): ... - def set_disposable(self, value: Any) -> None: ... - disposable: Any = ... - def dispose(self) -> None: ... diff --git a/stubs/rx/disposables/singleassignmentdisposable.pyi b/stubs/rx/disposables/singleassignmentdisposable.pyi deleted file mode 100644 --- a/stubs/rx/disposables/singleassignmentdisposable.pyi +++ /dev/null @@ -1,16 +0,0 @@ -# Stubs for rx.disposables.singleassignmentdisposable (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.core import Disposable -from typing import Any - -class SingleAssignmentDisposable(Disposable): - is_disposed: bool = ... - current: Any = ... - lock: Any = ... - def __init__(self) -> None: ... - def get_disposable(self): ... - def set_disposable(self, value: Any) -> None: ... - disposable: Any = ... - def dispose(self) -> None: ... diff --git a/stubs/rx/internal/__init__.pyi b/stubs/rx/internal/__init__.pyi deleted file mode 100644 --- a/stubs/rx/internal/__init__.pyi +++ /dev/null @@ -1,10 +0,0 @@ -# Stubs for rx.internal (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .basic import default_comparer, default_error, noop -from .enumerable import Enumerable -from .enumerator import Enumerator -from .exceptions import ArgumentOutOfRangeException, DisposedException, SequenceContainsNoElementsError -from .extensionmethod import extensionclassmethod, extensionmethod -from .priorityqueue import PriorityQueue diff --git a/stubs/rx/internal/basic.pyi b/stubs/rx/internal/basic.pyi deleted file mode 100644 --- a/stubs/rx/internal/basic.pyi +++ /dev/null @@ -1,13 +0,0 @@ -# Stubs for rx.internal.basic (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -def noop(*args: Any, **kw: Any) -> None: ... -def identity(x: Any): ... -def default_now(): ... -def default_comparer(x: Any, y: Any): ... -def default_sub_comparer(x: Any, y: Any): ... -def default_key_serializer(x: Any): ... -def default_error(err: Any) -> None: ... diff --git a/stubs/rx/internal/concurrency.pyi b/stubs/rx/internal/concurrency.pyi deleted file mode 100644 --- a/stubs/rx/internal/concurrency.pyi +++ /dev/null @@ -1,23 +0,0 @@ -# Stubs for rx.internal.concurrency (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -class RLock: - def locked(self): ... - def __enter__(self) -> None: ... - def __exit__(self, type: Any, value: Any, traceback: Any) -> None: ... - -class Event: - def is_set(self): ... - def set(self) -> None: ... - def clear(self) -> None: ... - def wait(self) -> None: ... - -class Condition: - def wait(self) -> None: ... - def aquire(self) -> None: ... - def release(self) -> None: ... - def notify(self, n: int = ...) -> None: ... - def notify_all(self) -> None: ... diff --git a/stubs/rx/internal/enumerable.pyi b/stubs/rx/internal/enumerable.pyi deleted file mode 100644 --- a/stubs/rx/internal/enumerable.pyi +++ /dev/null @@ -1,19 +0,0 @@ -# Stubs for rx.internal.enumerable (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .basic import identity -from typing import Any, Optional - -class Enumerable: - def __init__(self, iterator: Any) -> None: ... - def __iter__(self): ... - def where(self, predicate: Any): ... - def select(self, selector: Optional[Any] = ...): ... - def take(self, count: Any): ... - @classmethod - def range(cls, start: Any, count: Any): ... - @classmethod - def repeat(cls, value: Any, count: Optional[Any] = ...): ... - @classmethod - def for_each(cls, source: Any, selector: Optional[Any] = ...): ... diff --git a/stubs/rx/internal/enumerator.pyi b/stubs/rx/internal/enumerator.pyi deleted file mode 100644 --- a/stubs/rx/internal/enumerator.pyi +++ /dev/null @@ -1,12 +0,0 @@ -# Stubs for rx.internal.enumerator (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -class Enumerator: - iterator: Any = ... - def __init__(self, next: Any) -> None: ... - def __next__(self): ... - next: Any = ... - def __iter__(self): ... diff --git a/stubs/rx/internal/exceptions.pyi b/stubs/rx/internal/exceptions.pyi deleted file mode 100644 --- a/stubs/rx/internal/exceptions.pyi +++ /dev/null @@ -1,26 +0,0 @@ -# Stubs for rx.internal.exceptions (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional - -class SequenceContainsNoElementsError(Exception): - def __init__(self, msg: Optional[Any] = ...) -> None: ... - -class ArgumentOutOfRangeException(ValueError): - def __init__(self, msg: Optional[Any] = ...) -> None: ... - -class DisposedException(Exception): - def __init__(self, msg: Optional[Any] = ...) -> None: ... - -class ReEntracyException(Exception): - def __init__(self, msg: Optional[Any] = ...) -> None: ... - -class CompletedException(Exception): - def __init__(self, msg: Optional[Any] = ...) -> None: ... - -class WouldBlockException(Exception): - def __init__(self, msg: Optional[Any] = ...) -> None: ... - -class InvalidOperationException(Exception): - def __init__(self, msg: Optional[Any] = ...) -> None: ... diff --git a/stubs/rx/internal/extensionmethod.pyi b/stubs/rx/internal/extensionmethod.pyi deleted file mode 100644 --- a/stubs/rx/internal/extensionmethod.pyi +++ /dev/null @@ -1,8 +0,0 @@ -# Stubs for rx.internal.extensionmethod (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional - -def extensionmethod(base: Any, name: Optional[Any] = ..., decorator: Optional[Any] = ..., instancemethod: bool = ..., alias: Optional[Any] = ...): ... -def extensionclassmethod(base: Any, name: Optional[Any] = ..., alias: Optional[Any] = ...): ... diff --git a/stubs/rx/internal/priorityqueue.pyi b/stubs/rx/internal/priorityqueue.pyi deleted file mode 100644 --- a/stubs/rx/internal/priorityqueue.pyi +++ /dev/null @@ -1,17 +0,0 @@ -# Stubs for rx.internal.priorityqueue (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any, Optional - -class PriorityQueue: - items: Any = ... - count: int = ... - lock: Any = ... - def __init__(self, capacity: Optional[Any] = ...) -> None: ... - def __len__(self): ... - def peek(self): ... - def remove_at(self, index: Any): ... - def dequeue(self): ... - def enqueue(self, item: Any) -> None: ... - def remove(self, item: Any): ... diff --git a/stubs/rx/internal/utils.pyi b/stubs/rx/internal/utils.pyi deleted file mode 100644 --- a/stubs/rx/internal/utils.pyi +++ /dev/null @@ -1,21 +0,0 @@ -# Stubs for rx.internal.utils (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .exceptions import DisposedException -from typing import Any - -def add_ref(xs: Any, r: Any): ... -def adapt_call(func: Any): ... -def check_disposed(this: Any) -> None: ... -def is_future(p: Any): ... - -class TimeInterval: - value: Any = ... - interval: Any = ... - def __init__(self, value: Any, interval: Any) -> None: ... - -class Timestamp: - value: Any = ... - timestamp: Any = ... - def __init__(self, value: Any, timestamp: Any) -> None: ... diff --git a/stubs/rx/joins/__init__.pyi b/stubs/rx/joins/__init__.pyi deleted file mode 100644 --- a/stubs/rx/joins/__init__.pyi +++ /dev/null @@ -1,6 +0,0 @@ -# Stubs for rx.joins (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .pattern import Pattern -from .plan import Plan diff --git a/stubs/rx/joins/activeplan.pyi b/stubs/rx/joins/activeplan.pyi deleted file mode 100644 --- a/stubs/rx/joins/activeplan.pyi +++ /dev/null @@ -1,14 +0,0 @@ -# Stubs for rx.joins.activeplan (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -class ActivePlan: - join_observer_list: Any = ... - on_next: Any = ... - on_completed: Any = ... - join_observers: Any = ... - def __init__(self, join_observer_list: Any, on_next: Any, on_completed: Any) -> None: ... - def dequeue(self) -> None: ... - def match(self) -> None: ... diff --git a/stubs/rx/joins/joinobserver.pyi b/stubs/rx/joins/joinobserver.pyi deleted file mode 100644 --- a/stubs/rx/joins/joinobserver.pyi +++ /dev/null @@ -1,19 +0,0 @@ -# Stubs for rx.joins.joinobserver (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.core import ObserverBase -from typing import Any - -class JoinObserver(ObserverBase): - source: Any = ... - on_error: Any = ... - queue: Any = ... - active_plans: Any = ... - subscription: Any = ... - is_disposed: bool = ... - def __init__(self, source: Any, on_error: Any) -> None: ... - def add_active_plan(self, active_plan: Any) -> None: ... - def subscribe(self) -> None: ... - def remove_active_plan(self, active_plan: Any) -> None: ... - def dispose(self) -> None: ... diff --git a/stubs/rx/joins/pattern.pyi b/stubs/rx/joins/pattern.pyi deleted file mode 100644 --- a/stubs/rx/joins/pattern.pyi +++ /dev/null @@ -1,13 +0,0 @@ -# Stubs for rx.joins.pattern (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .plan import Plan -from typing import Any - -class Pattern: - patterns: Any = ... - def __init__(self, patterns: Any) -> None: ... - def and_(self, other: Any): ... - def __and__(self, other: Any): ... - def then_do(self, selector: Any): ... diff --git a/stubs/rx/joins/plan.pyi b/stubs/rx/joins/plan.pyi deleted file mode 100644 --- a/stubs/rx/joins/plan.pyi +++ /dev/null @@ -1,14 +0,0 @@ -# Stubs for rx.joins.plan (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .activeplan import ActivePlan -from .joinobserver import JoinObserver -from typing import Any - -class Plan: - expression: Any = ... - selector: Any = ... - def __init__(self, expression: Any, selector: Any) -> None: ... - def activate(self, external_subscriptions: Any, observer: Any, deactivate: Any): ... - def plan_create_observer(self, external_subscriptions: Any, observable: Any, on_error: Any): ... diff --git a/stubs/rx/subjects/__init__.pyi b/stubs/rx/subjects/__init__.pyi deleted file mode 100644 --- a/stubs/rx/subjects/__init__.pyi +++ /dev/null @@ -1,8 +0,0 @@ -# Stubs for rx.subjects (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .asyncsubject import AsyncSubject -from .behaviorsubject import BehaviorSubject -from .replaysubject import ReplaySubject -from .subject import Subject diff --git a/stubs/rx/subjects/anonymoussubject.pyi b/stubs/rx/subjects/anonymoussubject.pyi deleted file mode 100644 --- a/stubs/rx/subjects/anonymoussubject.pyi +++ /dev/null @@ -1,14 +0,0 @@ -# Stubs for rx.subjects.anonymoussubject (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from rx.core import ObservableBase -from typing import Any - -class AnonymousSubject(ObservableBase): - observer: Any = ... - observable: Any = ... - def __init__(self, observer: Any, observable: Any) -> None: ... - def on_completed(self) -> None: ... - def on_error(self, exception: Any) -> None: ... - def on_next(self, value: Any) -> None: ... diff --git a/stubs/rx/subjects/asyncsubject.pyi b/stubs/rx/subjects/asyncsubject.pyi deleted file mode 100644 --- a/stubs/rx/subjects/asyncsubject.pyi +++ /dev/null @@ -1,22 +0,0 @@ -# Stubs for rx.subjects.asyncsubject (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .innersubscription import InnerSubscription -from rx.core import ObservableBase, Observer -from typing import Any - -class AsyncSubject(ObservableBase, Observer): - is_disposed: bool = ... - is_stopped: bool = ... - value: Any = ... - has_value: bool = ... - observers: Any = ... - exception: Any = ... - lock: Any = ... - def __init__(self) -> None: ... - def check_disposed(self) -> None: ... - def on_completed(self) -> None: ... - def on_error(self, exception: Any) -> None: ... - def on_next(self, value: Any) -> None: ... - def dispose(self) -> None: ... diff --git a/stubs/rx/subjects/behaviorsubject.pyi b/stubs/rx/subjects/behaviorsubject.pyi deleted file mode 100644 --- a/stubs/rx/subjects/behaviorsubject.pyi +++ /dev/null @@ -1,21 +0,0 @@ -# Stubs for rx.subjects.behaviorsubject (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .innersubscription import InnerSubscription -from rx.core import ObservableBase, Observer -from typing import Any - -class BehaviorSubject(ObservableBase, Observer): - value: Any = ... - observers: Any = ... - is_disposed: bool = ... - is_stopped: bool = ... - exception: Any = ... - lock: Any = ... - def __init__(self, value: Any) -> None: ... - def check_disposed(self) -> None: ... - def on_completed(self) -> None: ... - def on_error(self, error: Any) -> None: ... - def on_next(self, value: Any) -> None: ... - def dispose(self) -> None: ... diff --git a/stubs/rx/subjects/innersubscription.pyi b/stubs/rx/subjects/innersubscription.pyi deleted file mode 100644 --- a/stubs/rx/subjects/innersubscription.pyi +++ /dev/null @@ -1,12 +0,0 @@ -# Stubs for rx.subjects.innersubscription (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from typing import Any - -class InnerSubscription: - subject: Any = ... - observer: Any = ... - lock: Any = ... - def __init__(self, subject: Any, observer: Any) -> None: ... - def dispose(self) -> None: ... diff --git a/stubs/rx/subjects/replaysubject.pyi b/stubs/rx/subjects/replaysubject.pyi deleted file mode 100644 --- a/stubs/rx/subjects/replaysubject.pyi +++ /dev/null @@ -1,30 +0,0 @@ -# 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: ... diff --git a/stubs/rx/subjects/subject.pyi b/stubs/rx/subjects/subject.pyi deleted file mode 100644 --- a/stubs/rx/subjects/subject.pyi +++ /dev/null @@ -1,23 +0,0 @@ -# Stubs for rx.subjects.subject (Python 3) -# -# NOTE: This dynamically typed stub was automatically generated by stubgen. - -from .anonymoussubject import AnonymousSubject -from .innersubscription import InnerSubscription -from rx.core import ObservableBase, Observer -from typing import Any - -class Subject(ObservableBase, Observer): - is_disposed: bool = ... - is_stopped: bool = ... - observers: Any = ... - exception: Any = ... - lock: Any = ... - def __init__(self) -> None: ... - def check_disposed(self) -> None: ... - def on_completed(self) -> None: ... - def on_error(self, exception: Any) -> None: ... - def on_next(self, value: Any) -> None: ... - def dispose(self) -> None: ... - @classmethod - def create(cls, observer: Any, observable: Any): ...