initial commit
tests pass
Added ChannelObservable.subscribe
Use a custom SuspendableClassifier
minor fix in classifier
map Observable.onError(Throwable) to SendPort.close(Throwable) in
-
Added ChannelObservable.get
Added BlockingObservable
OperationAll to OperatorAll
Reimplement the 'single' operator
Add first, last, single to rxjava-scala
Throw NoSuchElementException in the first, last and single operators when the Observable is empty
Rename OperationFirstOrDefaultTest and OperationLastTest to OperatorFirstOrDefaultTest and OperatorLastTest
Fix clojure test
Fix tests in rxjava-math
Notifications for the allocation adverse.
Fixed deadlock in Subjects + OperatorCache.
Merge pull request #970 from abersnaze/notification-lite

Notifications for the allocation adverse.
Merge with Serialize

- concurrency unit tests
- handle Observable that emits onComplete multiple times