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.
Merge branch 'master' into single
Fix typos
Use Quasar 0.5.0 release