initial commit
tests pass
Added ChannelObservable.subscribe
Use a custom SuspendableClassifier
minor fix in classifier
Fixed an issue with the from(Reader) added a bunch of unit tests.
map Observable.onError(Throwable) to SendPort.close(Throwable) in
-
Remove Bad Filter Logic

This code was accidentally committed during exploration of groupBy/subscribeOn.
Merge pull request #887 from benjchristensen/filter-cleanup

Remove Bad Filter Logic
Revert Bounded ObserveOn
Merge pull request #888 from benjchristensen/observeOn-bounded-unbounded

Revert Bounded ObserveOn
Split SubscribeOn into SubscribeOn/UnsubscribeOn

Working with @headinthebox based on discussions at https://github.com/Netflix/RxJava/pull/869 and https://github.com/Netflix/RxJava/pull/880#issuecomment-35163539 we determined that there are times when `unsubscribeOn` behavior is needed.

The `subscribeOn` operator can not mix `subscribe` and `unsubscribe` scheduling behavior without breaking the `lift`/`Subscriber` behavior that allows unsubscribing synchronous sources. The newly added `unsubscribeOn` operator will not work with synchronous unsubscribes, but it will work for the targeted use cases such as UI event handlers.
Merge pull request #890 from benjchristensen/subscribeOn-subscriptions

Split SubscribeOn into SubscribeOn/UnsubscribeOn
Move Exception Classes to rx.exceptions

Eliminate dumping ground of rx.util
Move time based util classes to rx.schedulers

Eliminate dumping ground of rx.util
Update sub-modules
Move rx.util.functions to rx.functions

Eliminate dumping ground of rx.util
Remove rx.util usage from sub-modules

All sub-modules and tests building and passing
rx.util.functions deprecated proxies