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
Fixed deadlock in Subjects + OperatorCache.
Chain Subscription in TimeoutSubscriber and SerializedSubscriber
Reimplement the ElementAt operator
Add ElementAt and ElementAtOrDefault to rxjava-scala