gistfile1.txt

/nix/store/69yd103b3vfxm3rdd5d0rga9g73fbfyd-python3.6-rx-1.6.1
├── lib
│   └── python3.6
│       └── site-packages
│           ├── rx
│           │   ├── backpressure
│           │   │   ├── controlledobservable.py
│           │   │   ├── controlledsubject.py
│           │   │   ├── __init__.py
│           │   │   ├── pausablebuffered.py
│           │   │   ├── pausable.py
│           │   │   ├── __pycache__
│           │   │   │   ├── controlledobservable.cpython-36.pyc
│           │   │   │   ├── controlledsubject.cpython-36.pyc
│           │   │   │   ├── __init__.cpython-36.pyc
│           │   │   │   ├── pausablebuffered.cpython-36.pyc
│           │   │   │   ├── pausable.cpython-36.pyc
│           │   │   │   ├── stopandwait.cpython-36.pyc
│           │   │   │   ├── stopandwaitobservable.cpython-36.pyc
│           │   │   │   ├── windowed.cpython-36.pyc
│           │   │   │   └── windowedobservable.cpython-36.pyc
│           │   │   ├── stopandwaitobservable.py
│           │   │   ├── stopandwait.py
│           │   │   ├── windowedobservable.py
│           │   │   └── windowed.py
│           │   ├── concurrency
│           │   │   ├── catchscheduler.py
│           │   │   ├── currentthreadscheduler.py
│           │   │   ├── eventloopscheduler.py
│           │   │   ├── historicalscheduler.py
│           │   │   ├── immediatescheduler.py
│           │   │   ├── __init__.py
│           │   │   ├── mainloopscheduler
│           │   │   │   ├── asyncioscheduler.py
│           │   │   │   ├── eventletscheduler.py
│           │   │   │   ├── geventscheduler.py
│           │   │   │   ├── gtkscheduler.py
│           │   │   │   ├── __init__.py
│           │   │   │   ├── ioloopscheduler.py
│           │   │   │   ├── __pycache__
│           │   │   │   │   ├── asyncioscheduler.cpython-36.pyc
│           │   │   │   │   ├── eventletscheduler.cpython-36.pyc
│           │   │   │   │   ├── geventscheduler.cpython-36.pyc
│           │   │   │   │   ├── gtkscheduler.cpython-36.pyc
│           │   │   │   │   ├── __init__.cpython-36.pyc
│           │   │   │   │   ├── ioloopscheduler.cpython-36.pyc
│           │   │   │   │   ├── pygamescheduler.cpython-36.pyc
│           │   │   │   │   ├── qtscheduler.cpython-36.pyc
│           │   │   │   │   ├── tkinterscheduler.cpython-36.pyc
│           │   │   │   │   ├── twistedscheduler.cpython-36.pyc
│           │   │   │   │   └── wxscheduler.cpython-36.pyc
│           │   │   │   ├── pygamescheduler.py
│           │   │   │   ├── qtscheduler.py
│           │   │   │   ├── tkinterscheduler.py
│           │   │   │   ├── twistedscheduler.py
│           │   │   │   └── wxscheduler.py
│           │   │   ├── newthreadscheduler.py
│           │   │   ├── __pycache__
│           │   │   │   ├── catchscheduler.cpython-36.pyc
│           │   │   │   ├── currentthreadscheduler.cpython-36.pyc
│           │   │   │   ├── eventloopscheduler.cpython-36.pyc
│           │   │   │   ├── historicalscheduler.cpython-36.pyc
│           │   │   │   ├── immediatescheduler.cpython-36.pyc
│           │   │   │   ├── __init__.cpython-36.pyc
│           │   │   │   ├── newthreadscheduler.cpython-36.pyc
│           │   │   │   ├── scheduleditem.cpython-36.pyc
│           │   │   │   ├── scheduleperiodic.cpython-36.pyc
│           │   │   │   ├── schedulerbase.cpython-36.pyc
│           │   │   │   ├── threadpoolscheduler.cpython-36.pyc
│           │   │   │   ├── timeoutscheduler.cpython-36.pyc
│           │   │   │   └── virtualtimescheduler.cpython-36.pyc
│           │   │   ├── scheduleditem.py
│           │   │   ├── scheduleperiodic.py
│           │   │   ├── schedulerbase.py
│           │   │   ├── threadpoolscheduler.py
│           │   │   ├── timeoutscheduler.py
│           │   │   └── virtualtimescheduler.py
│           │   ├── core
│           │   │   ├── anonymousobservable.py
│           │   │   ├── anonymousobserver.py
│           │   │   ├── autodetachobserver.py
│           │   │   ├── blockingobservable.py
│           │   │   ├── checkedobserver.py
│           │   │   ├── disposableextensions.py
│           │   │   ├── __init__.py
│           │   │   ├── notification.py
│           │   │   ├── observablebase.py
│           │   │   ├── observeonobserver.py
│           │   │   ├── observerbase.py
│           │   │   ├── observerextensions.py
│           │   │   ├── py2
│           │   │   │   ├── disposable.py
│           │   │   │   ├── __init__.py
│           │   │   │   ├── observable.py
│           │   │   │   ├── observer.py
│           │   │   │   ├── __pycache__
│           │   │   │   │   ├── disposable.cpython-36.pyc
│           │   │   │   │   ├── __init__.cpython-36.pyc
│           │   │   │   │   ├── observable.cpython-36.pyc
│           │   │   │   │   ├── observer.cpython-36.pyc
│           │   │   │   │   └── scheduler.cpython-36.pyc
│           │   │   │   └── scheduler.py
│           │   │   ├── py3
│           │   │   │   ├── disposable.py
│           │   │   │   ├── __init__.py
│           │   │   │   ├── observable.py
│           │   │   │   ├── observer.py
│           │   │   │   ├── __pycache__
│           │   │   │   │   ├── disposable.cpython-36.pyc
│           │   │   │   │   ├── __init__.cpython-36.pyc
│           │   │   │   │   ├── observable.cpython-36.pyc
│           │   │   │   │   ├── observer.cpython-36.pyc
│           │   │   │   │   └── scheduler.cpython-36.pyc
│           │   │   │   └── scheduler.py
│           │   │   ├── __pycache__
│           │   │   │   ├── anonymousobservable.cpython-36.pyc
│           │   │   │   ├── anonymousobserver.cpython-36.pyc
│           │   │   │   ├── autodetachobserver.cpython-36.pyc
│           │   │   │   ├── blockingobservable.cpython-36.pyc
│           │   │   │   ├── checkedobserver.cpython-36.pyc
│           │   │   │   ├── disposableextensions.cpython-36.pyc
│           │   │   │   ├── __init__.cpython-36.pyc
│           │   │   │   ├── notification.cpython-36.pyc
│           │   │   │   ├── observablebase.cpython-36.pyc
│           │   │   │   ├── observeonobserver.cpython-36.pyc
│           │   │   │   ├── observerbase.cpython-36.pyc
│           │   │   │   ├── observerextensions.cpython-36.pyc
│           │   │   │   └── scheduledobserver.cpython-36.pyc
│           │   │   └── scheduledobserver.py
│           │   ├── disposables
│           │   │   ├── anonymousdisposable.py
│           │   │   ├── booleandisposable.py
│           │   │   ├── compositedisposable.py
│           │   │   ├── __init__.py
│           │   │   ├── multipleassignmentdisposable.py
│           │   │   ├── __pycache__
│           │   │   │   ├── anonymousdisposable.cpython-36.pyc
│           │   │   │   ├── booleandisposable.cpython-36.pyc
│           │   │   │   ├── compositedisposable.cpython-36.pyc
│           │   │   │   ├── __init__.cpython-36.pyc
│           │   │   │   ├── multipleassignmentdisposable.cpython-36.pyc
│           │   │   │   ├── refcountdisposable.cpython-36.pyc
│           │   │   │   ├── scheduleddisposable.cpython-36.pyc
│           │   │   │   ├── serialdisposable.cpython-36.pyc
│           │   │   │   └── singleassignmentdisposable.cpython-36.pyc
│           │   │   ├── refcountdisposable.py
│           │   │   ├── scheduleddisposable.py
│           │   │   ├── serialdisposable.py
│           │   │   └── singleassignmentdisposable.py
│           │   ├── __init__.py
│           │   ├── internal
│           │   │   ├── basic.py
│           │   │   ├── concurrency.py
│           │   │   ├── enumerable.py
│           │   │   ├── enumerator.py
│           │   │   ├── exceptions.py
│           │   │   ├── extensionmethod.py
│           │   │   ├── __init__.py
│           │   │   ├── priorityqueue.py
│           │   │   ├── __pycache__
│           │   │   │   ├── basic.cpython-36.pyc
│           │   │   │   ├── concurrency.cpython-36.pyc
│           │   │   │   ├── enumerable.cpython-36.pyc
│           │   │   │   ├── enumerator.cpython-36.pyc
│           │   │   │   ├── exceptions.cpython-36.pyc
│           │   │   │   ├── extensionmethod.cpython-36.pyc
│           │   │   │   ├── __init__.cpython-36.pyc
│           │   │   │   ├── priorityqueue.cpython-36.pyc
│           │   │   │   └── utils.cpython-36.pyc
│           │   │   └── utils.py
│           │   ├── joins
│           │   │   ├── activeplan.py
│           │   │   ├── __init__.py
│           │   │   ├── joinobserver.py
│           │   │   ├── pattern.py
│           │   │   ├── plan.py
│           │   │   └── __pycache__
│           │   │       ├── activeplan.cpython-36.pyc
│           │   │       ├── __init__.cpython-36.pyc
│           │   │       ├── joinobserver.cpython-36.pyc
│           │   │       ├── pattern.cpython-36.pyc
│           │   │       └── plan.cpython-36.pyc
│           │   ├── linq
│           │   │   ├── connectableobservable.py
│           │   │   ├── enumerable
│           │   │   │   ├── __init__.py
│           │   │   │   ├── __pycache__
│           │   │   │   │   ├── __init__.cpython-36.pyc
│           │   │   │   │   └── whiledo.cpython-36.pyc
│           │   │   │   └── whiledo.py
│           │   │   ├── groupedobservable.py
│           │   │   ├── __init__.py
│           │   │   ├── observable
│           │   │   │   ├── all.py
│           │   │   │   ├── amb.py
│           │   │   │   ├── and_.py
│           │   │   │   ├── asobservable.py
│           │   │   │   ├── average.py
│           │   │   │   ├── blocking
│           │   │   │   │   ├── first.py
│           │   │   │   │   ├── foreach.py
│           │   │   │   │   ├── __init__.py
│           │   │   │   │   ├── last.py
│           │   │   │   │   ├── __pycache__
│           │   │   │   │   │   ├── first.cpython-36.pyc
│           │   │   │   │   │   ├── foreach.cpython-36.pyc
│           │   │   │   │   │   ├── __init__.cpython-36.pyc
│           │   │   │   │   │   ├── last.cpython-36.pyc
│           │   │   │   │   │   └── toiterable.cpython-36.pyc
│           │   │   │   │   └── toiterable.py
│           │   │   │   ├── buffer.py
│           │   │   │   ├── bufferwithtimeorcount.py
│           │   │   │   ├── bufferwithtime.py
│           │   │   │   ├── case.py
│           │   │   │   ├── catch.py
│           │   │   │   ├── combinelatest.py
│           │   │   │   ├── concat.py
│           │   │   │   ├── contains.py
│           │   │   │   ├── count.py
│           │   │   │   ├── create.py
│           │   │   │   ├── debounce.py
│           │   │   │   ├── defaultifempty.py
│           │   │   │   ├── defer.py
│           │   │   │   ├── delay.py
│           │   │   │   ├── delaysubscription.py
│           │   │   │   ├── delaywithselector.py
│           │   │   │   ├── dematerialize.py
│           │   │   │   ├── distinct.py
│           │   │   │   ├── distinctuntilchanged.py
│           │   │   │   ├── doaction.py
│           │   │   │   ├── dowhile.py
│           │   │   │   ├── elementatordefault.py
│           │   │   │   ├── elementat.py
│           │   │   │   ├── empty.py
│           │   │   │   ├── exclusive.py
│           │   │   │   ├── expand.py
│           │   │   │   ├── finallyaction.py
│           │   │   │   ├── findindex.py
│           │   │   │   ├── find.py
│           │   │   │   ├── firstordefault.py
│           │   │   │   ├── first.py
│           │   │   │   ├── forin.py
│           │   │   │   ├── fromcallback.py
│           │   │   │   ├── fromfuture.py
│           │   │   │   ├── fromiterable.py
│           │   │   │   ├── generate.py
│           │   │   │   ├── generatewithrelativetime.py
│           │   │   │   ├── groupby.py
│           │   │   │   ├── groupbyuntil.py
│           │   │   │   ├── groupjoin.py
│           │   │   │   ├── ifthen.py
│           │   │   │   ├── ignoreelements.py
│           │   │   │   ├── __init__.py
│           │   │   │   ├── interval.py
│           │   │   │   ├── isempty.py
│           │   │   │   ├── join.py
│           │   │   │   ├── lastordefault.py
│           │   │   │   ├── last.py
│           │   │   │   ├── let.py
│           │   │   │   ├── manyselect.py
│           │   │   │   ├── materialize.py
│           │   │   │   ├── maxby.py
│           │   │   │   ├── max.py
│           │   │   │   ├── merge.py
│           │   │   │   ├── minby.py
│           │   │   │   ├── min.py
│           │   │   │   ├── multicast.py
│           │   │   │   ├── never.py
│           │   │   │   ├── observeon.py
│           │   │   │   ├── of.py
│           │   │   │   ├── onerrorresumenext.py
│           │   │   │   ├── pairwise.py
│           │   │   │   ├── partition.py
│           │   │   │   ├── pluck.py
│           │   │   │   ├── publish.py
│           │   │   │   ├── publishvalue.py
│           │   │   │   ├── __pycache__
│           │   │   │   │   ├── all.cpython-36.pyc
│           │   │   │   │   ├── amb.cpython-36.pyc
│           │   │   │   │   ├── and_.cpython-36.pyc
│           │   │   │   │   ├── asobservable.cpython-36.pyc
│           │   │   │   │   ├── average.cpython-36.pyc
│           │   │   │   │   ├── buffer.cpython-36.pyc
│           │   │   │   │   ├── bufferwithtime.cpython-36.pyc
│           │   │   │   │   ├── bufferwithtimeorcount.cpython-36.pyc
│           │   │   │   │   ├── case.cpython-36.pyc
│           │   │   │   │   ├── catch.cpython-36.pyc
│           │   │   │   │   ├── combinelatest.cpython-36.pyc
│           │   │   │   │   ├── concat.cpython-36.pyc
│           │   │   │   │   ├── contains.cpython-36.pyc
│           │   │   │   │   ├── count.cpython-36.pyc
│           │   │   │   │   ├── create.cpython-36.pyc
│           │   │   │   │   ├── debounce.cpython-36.pyc
│           │   │   │   │   ├── defaultifempty.cpython-36.pyc
│           │   │   │   │   ├── defer.cpython-36.pyc
│           │   │   │   │   ├── delay.cpython-36.pyc
│           │   │   │   │   ├── delaysubscription.cpython-36.pyc
│           │   │   │   │   ├── delaywithselector.cpython-36.pyc
│           │   │   │   │   ├── dematerialize.cpython-36.pyc
│           │   │   │   │   ├── distinct.cpython-36.pyc
│           │   │   │   │   ├── distinctuntilchanged.cpython-36.pyc
│           │   │   │   │   ├── doaction.cpython-36.pyc
│           │   │   │   │   ├── dowhile.cpython-36.pyc
│           │   │   │   │   ├── elementat.cpython-36.pyc
│           │   │   │   │   ├── elementatordefault.cpython-36.pyc
│           │   │   │   │   ├── empty.cpython-36.pyc
│           │   │   │   │   ├── exclusive.cpython-36.pyc
│           │   │   │   │   ├── expand.cpython-36.pyc
│           │   │   │   │   ├── finallyaction.cpython-36.pyc
│           │   │   │   │   ├── find.cpython-36.pyc
│           │   │   │   │   ├── findindex.cpython-36.pyc
│           │   │   │   │   ├── first.cpython-36.pyc
│           │   │   │   │   ├── firstordefault.cpython-36.pyc
│           │   │   │   │   ├── forin.cpython-36.pyc
│           │   │   │   │   ├── fromcallback.cpython-36.pyc
│           │   │   │   │   ├── fromfuture.cpython-36.pyc
│           │   │   │   │   ├── fromiterable.cpython-36.pyc
│           │   │   │   │   ├── generate.cpython-36.pyc
│           │   │   │   │   ├── generatewithrelativetime.cpython-36.pyc
│           │   │   │   │   ├── groupby.cpython-36.pyc
│           │   │   │   │   ├── groupbyuntil.cpython-36.pyc
│           │   │   │   │   ├── groupjoin.cpython-36.pyc
│           │   │   │   │   ├── ifthen.cpython-36.pyc
│           │   │   │   │   ├── ignoreelements.cpython-36.pyc
│           │   │   │   │   ├── __init__.cpython-36.pyc
│           │   │   │   │   ├── interval.cpython-36.pyc
│           │   │   │   │   ├── isempty.cpython-36.pyc
│           │   │   │   │   ├── join.cpython-36.pyc
│           │   │   │   │   ├── last.cpython-36.pyc
│           │   │   │   │   ├── lastordefault.cpython-36.pyc
│           │   │   │   │   ├── let.cpython-36.pyc
│           │   │   │   │   ├── manyselect.cpython-36.pyc
│           │   │   │   │   ├── materialize.cpython-36.pyc
│           │   │   │   │   ├── maxby.cpython-36.pyc
│           │   │   │   │   ├── max.cpython-36.pyc
│           │   │   │   │   ├── merge.cpython-36.pyc
│           │   │   │   │   ├── minby.cpython-36.pyc
│           │   │   │   │   ├── min.cpython-36.pyc
│           │   │   │   │   ├── multicast.cpython-36.pyc
│           │   │   │   │   ├── never.cpython-36.pyc
│           │   │   │   │   ├── observeon.cpython-36.pyc
│           │   │   │   │   ├── of.cpython-36.pyc
│           │   │   │   │   ├── onerrorresumenext.cpython-36.pyc
│           │   │   │   │   ├── pairwise.cpython-36.pyc
│           │   │   │   │   ├── partition.cpython-36.pyc
│           │   │   │   │   ├── pluck.cpython-36.pyc
│           │   │   │   │   ├── publish.cpython-36.pyc
│           │   │   │   │   ├── publishvalue.cpython-36.pyc
│           │   │   │   │   ├── range.cpython-36.pyc
│           │   │   │   │   ├── reduce.cpython-36.pyc
│           │   │   │   │   ├── repeat.cpython-36.pyc
│           │   │   │   │   ├── replay.cpython-36.pyc
│           │   │   │   │   ├── retry.cpython-36.pyc
│           │   │   │   │   ├── returnvalue.cpython-36.pyc
│           │   │   │   │   ├── sample.cpython-36.pyc
│           │   │   │   │   ├── scan.cpython-36.pyc
│           │   │   │   │   ├── select.cpython-36.pyc
│           │   │   │   │   ├── selectmany.cpython-36.pyc
│           │   │   │   │   ├── selectswitch.cpython-36.pyc
│           │   │   │   │   ├── sequenceequal.cpython-36.pyc
│           │   │   │   │   ├── single.cpython-36.pyc
│           │   │   │   │   ├── singleordefault.cpython-36.pyc
│           │   │   │   │   ├── skip.cpython-36.pyc
│           │   │   │   │   ├── skiplast.cpython-36.pyc
│           │   │   │   │   ├── skiplastwithtime.cpython-36.pyc
│           │   │   │   │   ├── skipuntil.cpython-36.pyc
│           │   │   │   │   ├── skipuntilwithtime.cpython-36.pyc
│           │   │   │   │   ├── skipwhile.cpython-36.pyc
│           │   │   │   │   ├── skipwithtime.cpython-36.pyc
│           │   │   │   │   ├── slice.cpython-36.pyc
│           │   │   │   │   ├── some.cpython-36.pyc
│           │   │   │   │   ├── startasync.cpython-36.pyc
│           │   │   │   │   ├── start.cpython-36.pyc
│           │   │   │   │   ├── startswith.cpython-36.pyc
│           │   │   │   │   ├── statistics.cpython-36.pyc
│           │   │   │   │   ├── subscribeon.cpython-36.pyc
│           │   │   │   │   ├── sum.cpython-36.pyc
│           │   │   │   │   ├── switchlatest.cpython-36.pyc
│           │   │   │   │   ├── take.cpython-36.pyc
│           │   │   │   │   ├── takelastbuffer.cpython-36.pyc
│           │   │   │   │   ├── takelast.cpython-36.pyc
│           │   │   │   │   ├── takelastwithtime.cpython-36.pyc
│           │   │   │   │   ├── takeuntil.cpython-36.pyc
│           │   │   │   │   ├── takeuntilwithtime.cpython-36.pyc
│           │   │   │   │   ├── takewhile.cpython-36.pyc
│           │   │   │   │   ├── takewithtime.cpython-36.pyc
│           │   │   │   │   ├── thendo.cpython-36.pyc
│           │   │   │   │   ├── throttlefirst.cpython-36.pyc
│           │   │   │   │   ├── throw.cpython-36.pyc
│           │   │   │   │   ├── timeinterval.cpython-36.pyc
│           │   │   │   │   ├── timeout.cpython-36.pyc
│           │   │   │   │   ├── timeoutwithselector.cpython-36.pyc
│           │   │   │   │   ├── timer.cpython-36.pyc
│           │   │   │   │   ├── timestamp.cpython-36.pyc
│           │   │   │   │   ├── toasync.cpython-36.pyc
│           │   │   │   │   ├── toblocking.cpython-36.pyc
│           │   │   │   │   ├── todict.cpython-36.pyc
│           │   │   │   │   ├── tofuture.cpython-36.pyc
│           │   │   │   │   ├── toiterable.cpython-36.pyc
│           │   │   │   │   ├── tolist.cpython-36.pyc
│           │   │   │   │   ├── toset.cpython-36.pyc
│           │   │   │   │   ├── transduce.cpython-36.pyc
│           │   │   │   │   ├── using.cpython-36.pyc
│           │   │   │   │   ├── when.cpython-36.pyc
│           │   │   │   │   ├── where.cpython-36.pyc
│           │   │   │   │   ├── whiledo.cpython-36.pyc
│           │   │   │   │   ├── window.cpython-36.pyc
│           │   │   │   │   ├── windowwithcount.cpython-36.pyc
│           │   │   │   │   ├── windowwithtime.cpython-36.pyc
│           │   │   │   │   ├── windowwithtimeorcount.cpython-36.pyc
│           │   │   │   │   ├── withlatestfrom.cpython-36.pyc
│           │   │   │   │   ├── ziparray.cpython-36.pyc
│           │   │   │   │   └── zip.cpython-36.pyc
│           │   │   │   ├── range.py
│           │   │   │   ├── reduce.py
│           │   │   │   ├── repeat.py
│           │   │   │   ├── replay.py
│           │   │   │   ├── retry.py
│           │   │   │   ├── returnvalue.py
│           │   │   │   ├── sample.py
│           │   │   │   ├── scan.py
│           │   │   │   ├── selectmany.py
│           │   │   │   ├── select.py
│           │   │   │   ├── selectswitch.py
│           │   │   │   ├── sequenceequal.py
│           │   │   │   ├── singleordefault.py
│           │   │   │   ├── single.py
│           │   │   │   ├── skiplast.py
│           │   │   │   ├── skiplastwithtime.py
│           │   │   │   ├── skip.py
│           │   │   │   ├── skipuntil.py
│           │   │   │   ├── skipuntilwithtime.py
│           │   │   │   ├── skipwhile.py
│           │   │   │   ├── skipwithtime.py
│           │   │   │   ├── slice.py
│           │   │   │   ├── some.py
│           │   │   │   ├── startasync.py
│           │   │   │   ├── start.py
│           │   │   │   ├── startswith.py
│           │   │   │   ├── statistics.py
│           │   │   │   ├── subscribeon.py
│           │   │   │   ├── sum.py
│           │   │   │   ├── switchlatest.py
│           │   │   │   ├── takelastbuffer.py
│           │   │   │   ├── takelast.py
│           │   │   │   ├── takelastwithtime.py
│           │   │   │   ├── take.py
│           │   │   │   ├── takeuntil.py
│           │   │   │   ├── takeuntilwithtime.py
│           │   │   │   ├── takewhile.py
│           │   │   │   ├── takewithtime.py
│           │   │   │   ├── thendo.py
│           │   │   │   ├── throttlefirst.py
│           │   │   │   ├── throw.py
│           │   │   │   ├── timeinterval.py
│           │   │   │   ├── timeout.py
│           │   │   │   ├── timeoutwithselector.py
│           │   │   │   ├── timer.py
│           │   │   │   ├── timestamp.py
│           │   │   │   ├── toasync.py
│           │   │   │   ├── toblocking.py
│           │   │   │   ├── todict.py
│           │   │   │   ├── tofuture.py
│           │   │   │   ├── toiterable.py
│           │   │   │   ├── tolist.py
│           │   │   │   ├── toset.py
│           │   │   │   ├── transduce.py
│           │   │   │   ├── using.py
│           │   │   │   ├── when.py
│           │   │   │   ├── where.py
│           │   │   │   ├── whiledo.py
│           │   │   │   ├── window.py
│           │   │   │   ├── windowwithcount.py
│           │   │   │   ├── windowwithtimeorcount.py
│           │   │   │   ├── windowwithtime.py
│           │   │   │   ├── withlatestfrom.py
│           │   │   │   ├── ziparray.py
│           │   │   │   └── zip.py
│           │   │   └── __pycache__
│           │   │       ├── connectableobservable.cpython-36.pyc
│           │   │       ├── groupedobservable.cpython-36.pyc
│           │   │       └── __init__.cpython-36.pyc
│           │   ├── __pycache__
│           │   │   └── __init__.cpython-36.pyc
│           │   ├── subjects
│           │   │   ├── anonymoussubject.py
│           │   │   ├── asyncsubject.py
│           │   │   ├── behaviorsubject.py
│           │   │   ├── __init__.py
│           │   │   ├── innersubscription.py
│           │   │   ├── __pycache__
│           │   │   │   ├── anonymoussubject.cpython-36.pyc
│           │   │   │   ├── asyncsubject.cpython-36.pyc
│           │   │   │   ├── behaviorsubject.cpython-36.pyc
│           │   │   │   ├── __init__.cpython-36.pyc
│           │   │   │   ├── innersubscription.cpython-36.pyc
│           │   │   │   ├── replaysubject.cpython-36.pyc
│           │   │   │   └── subject.cpython-36.pyc
│           │   │   ├── replaysubject.py
│           │   │   └── subject.py
│           │   └── testing
│           │       ├── coldobservable.py
│           │       ├── dump.py
│           │       ├── hotobservable.py
│           │       ├── __init__.py
│           │       ├── marbles.py
│           │       ├── mockdisposable.py
│           │       ├── mockobserver.py
│           │       ├── __pycache__
│           │       │   ├── coldobservable.cpython-36.pyc
│           │       │   ├── dump.cpython-36.pyc
│           │       │   ├── hotobservable.cpython-36.pyc
│           │       │   ├── __init__.cpython-36.pyc
│           │       │   ├── marbles.cpython-36.pyc
│           │       │   ├── mockdisposable.cpython-36.pyc
│           │       │   ├── mockobserver.cpython-36.pyc
│           │       │   ├── reactive_assert.cpython-36.pyc
│           │       │   ├── reactivetest.cpython-36.pyc
│           │       │   ├── recorded.cpython-36.pyc
│           │       │   ├── subscription.cpython-36.pyc
│           │       │   └── testscheduler.cpython-36.pyc
│           │       ├── reactive_assert.py
│           │       ├── reactivetest.py
│           │       ├── recorded.py
│           │       ├── subscription.py
│           │       └── testscheduler.py
│           └── Rx-1.6.1.dist-info
│               ├── INSTALLER
│               ├── LICENSE
│               ├── METADATA
│               ├── RECORD
│               ├── top_level.txt
│               ├── WHEEL
│               └── zip-safe
└── nix-support
    └── propagated-build-inputs

37 directories, 498 files