--- a/light9/vidref/videorecorder.py	Wed Jun 05 23:14:49 2019 +0000
+++ b/light9/vidref/videorecorder.py	Thu Jun 06 00:05:50 2019 +0000
@@ -9,8 +9,8 @@
 
 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
 

--- a/requirements.txt	Wed Jun 05 23:14:49 2019 +0000
+++ b/requirements.txt	Thu Jun 06 00:05:50 2019 +0000
@@ -17,7 +17,7 @@
 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

--- a/stubs/rx/__init__.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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

--- a/stubs/rx/backpressure/__init__.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,4 +0,0 @@
-# Stubs for rx.backpressure (Python 3)
-#
-# NOTE: This dynamically typed stub was automatically generated by stubgen.
-

--- a/stubs/rx/backpressure/controlledobservable.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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] = ...): ...

--- a/stubs/rx/backpressure/controlledsubject.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/backpressure/pausable.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/backpressure/pausablebuffered.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/backpressure/stopandwait.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/backpressure/stopandwaitobservable.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/backpressure/windowed.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/backpressure/windowedobservable.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/concurrency/__init__.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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

--- a/stubs/rx/concurrency/catchscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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] = ...): ...

--- a/stubs/rx/concurrency/currentthreadscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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

--- a/stubs/rx/concurrency/eventloopscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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

--- a/stubs/rx/concurrency/historicalscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/concurrency/immediatescheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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

--- a/stubs/rx/concurrency/mainloopscheduler/__init__.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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

--- a/stubs/rx/concurrency/mainloopscheduler/asyncioscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/concurrency/mainloopscheduler/eventletscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/concurrency/mainloopscheduler/geventscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/concurrency/mainloopscheduler/gtkscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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] = ...): ...

--- a/stubs/rx/concurrency/mainloopscheduler/ioloopscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/concurrency/mainloopscheduler/pygamescheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/concurrency/mainloopscheduler/qtscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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] = ...): ...

--- a/stubs/rx/concurrency/mainloopscheduler/tkinterscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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] = ...): ...

--- a/stubs/rx/concurrency/mainloopscheduler/twistedscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/concurrency/mainloopscheduler/wxscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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] = ...): ...

--- a/stubs/rx/concurrency/newthreadscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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

--- a/stubs/rx/concurrency/scheduleditem.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/concurrency/scheduleperiodic.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/concurrency/schedulerbase.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/concurrency/threadpoolscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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

--- a/stubs/rx/concurrency/timeoutscheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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

--- a/stubs/rx/concurrency/virtualtimescheduler.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/disposables/__init__.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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

--- a/stubs/rx/disposables/anonymousdisposable.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/disposables/booleandisposable.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/disposables/compositedisposable.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/disposables/multipleassignmentdisposable.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/disposables/refcountdisposable.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/disposables/scheduleddisposable.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/disposables/serialdisposable.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/disposables/singleassignmentdisposable.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/internal/__init__.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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

--- a/stubs/rx/internal/basic.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/internal/concurrency.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/internal/enumerable.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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] = ...): ...

--- a/stubs/rx/internal/enumerator.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/internal/exceptions.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/internal/extensionmethod.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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] = ...): ...

--- a/stubs/rx/internal/priorityqueue.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/internal/utils.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/joins/__init__.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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

--- a/stubs/rx/joins/activeplan.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/joins/joinobserver.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/joins/pattern.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/joins/plan.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...

--- a/stubs/rx/subjects/__init__.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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

--- a/stubs/rx/subjects/anonymoussubject.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/subjects/asyncsubject.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/subjects/behaviorsubject.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/subjects/innersubscription.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/subjects/replaysubject.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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: ...

--- a/stubs/rx/subjects/subject.pyi	Wed Jun 05 23:14:49 2019 +0000
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -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): ...