Dag Brattli

You cannot use the CurrentThreadScheduler here. It cannot schedule blocking work on a single thread (current) without blocking everything else while waiting, so things will not behave as you expect....

It it's not easy to say. Multi-threaded applications can be complex to get right. You will have to experiment and get into the details of this. But you will have...

Great work! The main building blocks of Rx is the merge functions (`merge`, `switch_latest`, `concat`) combined with the mapper forms the functions we know as `flat_map` (i.e [map_merge](https://github.com/ReactiveX/RxPY/blob/master/reactivex/operators/_flatmap.py#L34)), `switch_map` and...

@hamstap85 One thing that worries me about this PR is that the tests are derived from `test_map` and not e.g `test_switchlatest`. Thus the tests do not have the notion of...

Docstrings should follow PEP-8, i.e 72 chars per line. PS: all the current tests for `switch_map` and `switch_map_index` pass if you replace `switch_map` with `flat_map` etc. The only difference is...

Could you please provide an example?

Hi, I think that `from_iterable` is working as intended. It cannot have any opinion if the iterable is it's own iterator or not. This is similar to the iterable world:...

You could try. Feel free to make a PR.

Please submit a *minimal self contained code example*. Minimal means that there should not be any other code. E.g what is `test_view`, `child`. Self-contained means that one should be able...

Yes, it's a problem that `subscribe` means both "attach" and "run" at the same time. Turning cold observables hot and then trying to make them feel cold again will give...