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
Observable.sample(Observable) in Scala
tweak RxScalaDemo (and Olympics example)
some RxScalaDemo tweaks
add Subscriber and Observable creation from `Subscriber[T] => Unit`
Merge branch 'master' of github.com:Netflix/RxJava into scala-additions
deprecate rx.lang.scala.Observable.create[T](Observer[T]=>Subscription)
Added BlockingObservable
Fix deadlock in SubscribeOnBounded
correct link to maven search
A number of improvements to OperatorObserveFromAndroidComponent

- move the UI thread assert out of the operator and into the helpers; this way, we don't fail the observer anymore with an exception, but the caller.
- do not loop unsubscribe through the main thread anymore. This unnecessarily defers releasing the references, and might in fact be processed only after Android creates the component after a rotation change. I had to make the references volatile for this to work.
- immediately unsubscribe in case we detect the componentRef has become invalid. This solves the problem that dangling observers would continue to listen to notifications with no observer alive anymore.

refs:
https://github.com/Netflix/RxJava/issues/754
https://github.com/Netflix/RxJava/issues/899
Initial commit of the Android samples module

refs https://github.com/soundcloud/RxJava/issues/3
add Observable.startWith(Observable) method and unit test to avoid breaking method chaining when want to startWith an Observable rather than just an Iterator or specific values.